Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrorBadRequestData = NewError(http.StatusBadRequest, "bad request data")
)
Functions ¶
This section is empty.
Types ¶
type Endpoint ¶
type Endpoint struct {
// contains filtered or unexported fields
}
type Error ¶
type Processor ¶
type Processor interface {
// Empty returns empty structure for request unmarshal or <nil> if request doesn't send any data.
Empty() interface{}
// Process handles URL and ingest structure and returns data or error
Process(ctx context.Context, u *url.URL, v interface{}) (res interface{}, err error)
}
Processor handles RPC path-method
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
func (*Router) ConsumeMessage ¶
ConsumeMessage accepts message with proto.NodesInfo
func (*Router) GetEndpoint ¶
type Server ¶
type Server struct {
*supervisor.Control
// contains filtered or unexported fields
}
func NewServer ¶
Source Files
¶
- endpoint.go
- error.go
- processor.go
- router.go
- server.go
Click to show internal directories.
Click to hide internal directories.