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) GetIndexKeys(ctx context.Context, req *grpc.GetIndexKeysRequest) (*grpc.GetIndexKeysResponse, error)
  • func (s *Server) GetLatestIndexKey(ctx context.Context, req *grpc.GetLatestIndexKeyRequest) (*grpc.GetLatestIndexKeyResponse, error)
  • func (s *Server) GetLatestObject(ctx context.Context, req *grpc.GetLatestObjectRequest) (*grpc.GetLatestObjectResponse, error)
  • func (s *Server) GetObjects(ctx context.Context, req *grpc.GetObjectsRequest) (*grpc.GetObjectsResponse, error)
  • func (s *Server) GetObjectsFromIndexKeys(ctx context.Context, req *grpc.GetObjectsFromIndexKeysRequest) (*grpc.GetObjectsFromIndexKeysResponse, 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

New creates a new Server instance.

func (*Server) GetIndexKeys

func (s *Server) GetIndexKeys(ctx context.Context, req *grpc.GetIndexKeysRequest) (*grpc.GetIndexKeysResponse, error)

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

func (*Server) GetLatestIndexKey

func (s *Server) GetLatestIndexKey(ctx context.Context, req *grpc.GetLatestIndexKeyRequest) (*grpc.GetLatestIndexKeyResponse, error)

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

func (*Server) GetLatestObject

func (s *Server) GetLatestObject(ctx context.Context, req *grpc.GetLatestObjectRequest) (*grpc.GetLatestObjectResponse, error)

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

func (*Server) GetObjects

func (s *Server) GetObjects(ctx context.Context, req *grpc.GetObjectsRequest) (*grpc.GetObjectsResponse, error)

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

func (*Server) GetObjectsFromIndexKeys

func (s *Server) GetObjectsFromIndexKeys(ctx context.Context, req *grpc.GetObjectsFromIndexKeysRequest) (*grpc.GetObjectsFromIndexKeysResponse, error)

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