rpc

Documentation

Overview

Package rpc provides the gRPC server implementation for the index repo service.

Index

• type Server
  • func NewServer(chConn clickhouse.Conn, objGetter indexrepo.ObjectGetter, ...) *Server
  • func (s *Server) GetLatestCloudEvent(ctx context.Context, req *grpc.GetLatestCloudEventRequest) (*grpc.GetLatestCloudEventResponse, error)
  • func (s *Server) GetLatestIndex(ctx context.Context, req *grpc.GetLatestIndexRequest) (*grpc.GetLatestIndexResponse, error)
  • func (s *Server) ListCloudEvents(ctx context.Context, req *grpc.ListCloudEventsRequest) (*grpc.ListCloudEventsResponse, error)
  • func (s *Server) ListCloudEventsFromIndex(ctx context.Context, req *grpc.ListCloudEventsFromKeysRequest) (*grpc.ListCloudEventsFromKeysResponse, error)
  • func (s *Server) ListIndex(ctx context.Context, req *grpc.ListIndexesRequest) (*grpc.ListIndexesResponse, error)

Types

type Server

type Server struct {
	grpc.UnimplementedFetchServiceServer
	// contains filtered or unexported fields
}

Server is used to implement grpc.IndexRepoServiceServer.

func NewServer

func NewServer(chConn clickhouse.Conn, objGetter indexrepo.ObjectGetter, cloudEventBucket, ephemeralBucket string) *Server

NewServer creates a new Server instance.

func (*Server) GetLatestCloudEvent

func (s *Server) GetLatestCloudEvent(ctx context.Context, req *grpc.GetLatestCloudEventRequest) (*grpc.GetLatestCloudEventResponse, error)

GetLatestCloudEvent translates the gRPC call to the indexrepo type and fetches the latest data for the given options.

func (*Server) GetLatestIndex

func (s *Server) GetLatestIndex(ctx context.Context, req *grpc.GetLatestIndexRequest) (*grpc.GetLatestIndexResponse, error)

GetLatestIndex translates the gRPC call to the indexrepo type and returns the latest index for the given options.

func (*Server) ListCloudEvents

func (s *Server) ListCloudEvents(ctx context.Context, req *grpc.ListCloudEventsRequest) (*grpc.ListCloudEventsResponse, error)

ListCloudEvents translates the gRPC call to the indexrepo type and fetches data for the given options.

func (*Server) ListCloudEventsFromIndex

func (s *Server) ListCloudEventsFromIndex(ctx context.Context, req *grpc.ListCloudEventsFromKeysRequest) (*grpc.ListCloudEventsFromKeysResponse, error)

ListCloudEventsFromIndex translates the gRPC call to the indexrepo type and fetches data for the given index keys.

func (*Server) ListIndex

func (s *Server) ListIndex(ctx context.Context, req *grpc.ListIndexesRequest) (*grpc.ListIndexesResponse, error)

ListIndex translates the gRPC call to the indexrepo type and fetches index keys for the given options.