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) GetLatestMetadata(ctx context.Context, req *grpc.GetLatestMetadataRequest) (*grpc.GetLatestMetadataResponse, error)
  • func (s *Server) ListCloudEvents(ctx context.Context, req *grpc.ListCloudEventsRequest) (*grpc.ListCloudEventsResponse, error)
  • func (s *Server) ListCloudEventsFromKeys(ctx context.Context, req *grpc.ListCloudEventsFromKeysRequest) (*grpc.ListCloudEventsFromKeysResponse, error)
  • func (s *Server) ListMetadata(ctx context.Context, req *grpc.ListMetadataRequest) (*grpc.ListMetadataResponse, 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) GetLatestMetadata

func (s *Server) GetLatestMetadata(ctx context.Context, req *grpc.GetLatestMetadataRequest) (*grpc.GetLatestMetadataResponse, error)

GetLatestMetadata translates the gRPC call to the indexrepo type and returns the latest metadata 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) ListCloudEventsFromKeys

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

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

func (*Server) ListMetadata

func (s *Server) ListMetadata(ctx context.Context, req *grpc.ListMetadataRequest) (*grpc.ListMetadataResponse, error)

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