rpc

Documentation

Index

• type Client
  • func NewClient(tcfg transport.Config) (*Client, error)
  • 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
  • func NewServer() *Server
  • func (s *Server) Init(ctx context.Context) error
  • func (s *Server) Shutdown()
• type ServerAdmin
  • func NewServerAdmin() *ServerAdmin
• type ServerIngestor
  • func NewServerIngestor() *ServerIngestor
  • func (si *ServerIngestor) Init(ctx context.Context) error
  • func (si *ServerIngestor) Shutdown()
• type ServerPipes
  • func NewServerPipes() *ServerPipes
• type ServerQuerier
  • func NewServerQuerier() *ServerQuerier

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is rpc client which provides the API interface for clients

func NewClient

func NewClient(tcfg transport.Config) (*Client, error)

NewClient creates new Client for connecting to the server, using the transport config tcfg

func (*Client) Close

func (c *Client) Close() error

func (*Client) EnsurePipe

func (c *Client) EnsurePipe(ctx context.Context, p api.Pipe, res *api.PipeCreateResult) error

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

func (*Client) Write

func (c *Client) Write(ctx context.Context, tags, fields string, evs []*api.LogEvent, res *api.WriteResult) 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
}

func NewServer

func NewServer() *Server

func (*Server) Init

func (s *Server) Init(ctx context.Context) error

Init is part of Initializer interface

func (*Server) Shutdown

func (s *Server) Shutdown()

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) Init

func (si *ServerIngestor) Init(ctx context.Context) error

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