rpc

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

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 struct {
	Admin *backend.Admin `inject:""`
	// contains filtered or unexported fields
}

type ServerIngestor struct {
	Journals *partition.Service `inject:""`
	MainCtx  context.Context    `inject:"mainCtx"`
	// contains filtered or unexported fields
}

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

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
}