Documentation ¶
Index ¶
- type Client
- func (c *Client) Close() error
- func (c *Client) EnsurePipe(ctx context.Context, p api.Pipe, res *api.PipeCreateResult) error
- func (c *Client) Execute(ctx context.Context, req api.ExecRequest) (api.ExecResult, error)
- func (c *Client) Query(ctx context.Context, qr *api.QueryRequest, res *api.QueryResult) error
- func (c *Client) Write(ctx context.Context, tags, fields string, evs []*api.LogEvent, ...) error
- type Server
- type ServerAdmin
- type ServerIngestor
- type ServerPipes
- type ServerQuerier
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is rpc client which provides the API interface for clients
func NewClient ¶
NewClient creates new rpc.Client for connecting to the server, using the transport config tcfg
func (*Client) EnsurePipe ¶
func (*Client) Execute ¶
func (c *Client) Execute(ctx context.Context, req api.ExecRequest) (api.ExecResult, error)
func (*Client) Query ¶
func (c *Client) Query(ctx context.Context, qr *api.QueryRequest, res *api.QueryResult) error
type Server ¶
type Server struct { ConnConfig transport.Config `inject:"publicRpcTransport"` SrvIngestor *ServerIngestor `inject:""` SrvQuerier *ServerQuerier `inject:""` SrvAdmin *ServerAdmin `inject:""` SrvPipes *ServerPipes `inject:""` // contains filtered or unexported fields }
type ServerAdmin ¶
type ServerAdmin struct { Admin *backend.Admin `inject:""` // contains filtered or unexported fields }
ServerAdmin implements server part of api.Admin interface
func NewServerAdmin ¶
func NewServerAdmin() *ServerAdmin
NewServerAdmin creates a new instance of ServerAdmin
type ServerIngestor ¶
type ServerIngestor struct { Journals *partition.Service `inject:""` MainCtx context.Context `inject:"mainCtx"` // contains filtered or unexported fields }
ServerIngestor is a struct, which provides the ingestor RPC functionality.
func NewServerIngestor ¶
func NewServerIngestor() *ServerIngestor
func (*ServerIngestor) Shutdown ¶
func (si *ServerIngestor) Shutdown()
type ServerPipes ¶
type ServerPipes struct { PipeService *pipe.Service `inject:""` // contains filtered or unexported fields }
ServerAdmin implements server part of api.Admin interface
func NewServerPipes ¶
func NewServerPipes() *ServerPipes
type ServerQuerier ¶
type ServerQuerier struct { CurProvider cursor.Provider `inject:""` MainCtx context.Context `inject:"mainCtx"` Pool *bytes.Pool `inject:""` Querier *backend.Querier `inject:""` // contains filtered or unexported fields }
func NewServerQuerier ¶
func NewServerQuerier() *ServerQuerier
Click to show internal directories.
Click to hide internal directories.