logrange: github.com/logrange/logrange/api/rpc Index | Files

package rpc

import "github.com/logrange/logrange/api/rpc"

Index

Package Files

admin.go client.go encoder.go ingestor.go pipes.go querier.go server.go

type Client Uses

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

Client is rpc client which provides the API interface for clients

func NewClient Uses

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

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

func (*Client) Close Uses

func (c *Client) Close() error

func (*Client) EnsurePipe Uses

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

func (*Client) Execute Uses

func (c *Client) Execute(ctx context.Context, req api.ExecRequest) (api.ExecResult, error)

func (*Client) Query Uses

func (c *Client) Query(ctx context.Context, qr *api.QueryRequest, res *api.QueryResult) error

func (*Client) Write Uses

func (c *Client) Write(ctx context.Context, tags, fields string, evs []*api.LogEvent, res *api.WriteResult) error

type Server Uses

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 Uses

func NewServer() *Server

func (*Server) Init Uses

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

Init is part of Initializer interface

func (*Server) Shutdown Uses

func (s *Server) Shutdown()

type ServerAdmin Uses

type ServerAdmin struct {
    Admin *backend.Admin `inject:""`
    // contains filtered or unexported fields
}

ServerAdmin implements server part of api.Admin interface

func NewServerAdmin Uses

func NewServerAdmin() *ServerAdmin

NewServerAdmin creates a new instance of ServerAdmin

type ServerIngestor Uses

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 Uses

func NewServerIngestor() *ServerIngestor

func (*ServerIngestor) Init Uses

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

func (*ServerIngestor) Shutdown Uses

func (si *ServerIngestor) Shutdown()

type ServerPipes Uses

type ServerPipes struct {
    PipeService *pipe.Service `inject:""`
    // contains filtered or unexported fields
}

ServerAdmin implements server part of api.Admin interface

func NewServerPipes Uses

func NewServerPipes() *ServerPipes

type ServerQuerier Uses

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 Uses

func NewServerQuerier() *ServerQuerier

Package rpc imports 22 packages (graph) and is imported by 2 packages. Updated 2019-08-06. Refresh now. Tools for package owners.