Documentation
¶
Index ¶
- type MessageConsumer
- type RequestProxy
- func (p *RequestProxy) AddTableFiles(_ context.Context, in *pb.AddTableFilesRequest) (*pb.AddTableFilesResponse, error)
- func (p *RequestProxy) Close()
- func (p *RequestProxy) Commit(_ context.Context, in *pb.CommitRequest) (*pb.CommitResponse, error)
- func (p *RequestProxy) GetDownloadLocations(ctx context.Context, in *pb.GetDownloadLocsRequest) (*pb.GetDownloadLocsResponse, error)
- func (p *RequestProxy) GetRepoMetadata(_ context.Context, in *pb.GetRepoMetadataRequest) (*pb.GetRepoMetadataResponse, error)
- func (p *RequestProxy) GetUploadLocations(ctx context.Context, in *pb.GetUploadLocsRequest) (*pb.GetUploadLocsResponse, error)
- func (p *RequestProxy) HasChunks(_ context.Context, in *pb.HasChunksRequest) (*pb.HasChunksResponse, error)
- func (p *RequestProxy) ListTableFiles(ctx context.Context, in *pb.ListTableFilesRequest) (*pb.ListTableFilesResponse, error)
- func (p *RequestProxy) Rebase(_ context.Context, in *pb.RebaseRequest) (*pb.RebaseResponse, error)
- func (p *RequestProxy) RefreshTableFileUrl(ctx context.Context, in *pb.RefreshTableFileUrlRequest) (*pb.RefreshTableFileUrlResponse, error)
- func (p *RequestProxy) Root(_ context.Context, in *pb.RootRequest) (*pb.RootResponse, error)
- func (p *RequestProxy) ServeHTTP(writer http.ResponseWriter, request *http.Request)
- func (p *RequestProxy) Start()
- func (p *RequestProxy) StreamDownloadLocations(stream pb.ChunkStoreService_StreamDownloadLocationsServer) (err error)
- type ResponseProxy
- type StreamDownloadLocationsClientEx
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageConsumer ¶
type MessageConsumer struct {
// contains filtered or unexported fields
}
MessageConsumer consumes events from an RPC kafka topic, en convert them into messages.
func NewMessageConsumer ¶
func NewMessageConsumer( kafkaConfig *kafka.ConfigMap, topic string, messageHandler func(message messages.Message)) *MessageConsumer
NewMessageConsumer creates a new MessageConsumer.
An MessageConsumer is created using a kafka configuration map, a topic name a message handler handling converted messages from events and possibly a function indicating to close the consumer.
func (*MessageConsumer) Close ¶
func (c *MessageConsumer) Close()
func (*MessageConsumer) Start ¶
func (c *MessageConsumer) Start()
Start creates a Kafka consumer and starts polling the consumer.
The events received from the consumer are send to the messageHandler function until either the isClosedFn function returns true, or the process is exited.
type RequestProxy ¶
type RequestProxy struct {
pb.UnimplementedChunkStoreServiceServer
// contains filtered or unexported fields
}
RequestProxy converts requests from a caller into the associated Kafka messages, and waits for Kafka responses.
func NewRequestProxy ¶
func NewRequestProxy(config *config.RequestProxyConfig) (*RequestProxy, error)
func (*RequestProxy) AddTableFiles ¶
func (p *RequestProxy) AddTableFiles(_ context.Context, in *pb.AddTableFilesRequest) (*pb.AddTableFilesResponse, error)
func (*RequestProxy) Close ¶
func (p *RequestProxy) Close()
func (*RequestProxy) Commit ¶
func (p *RequestProxy) Commit(_ context.Context, in *pb.CommitRequest) (*pb.CommitResponse, error)
func (*RequestProxy) GetDownloadLocations ¶
func (p *RequestProxy) GetDownloadLocations(ctx context.Context, in *pb.GetDownloadLocsRequest) (*pb.GetDownloadLocsResponse, error)
func (*RequestProxy) GetRepoMetadata ¶
func (p *RequestProxy) GetRepoMetadata(_ context.Context, in *pb.GetRepoMetadataRequest) (*pb.GetRepoMetadataResponse, error)
func (*RequestProxy) GetUploadLocations ¶
func (p *RequestProxy) GetUploadLocations(ctx context.Context, in *pb.GetUploadLocsRequest) (*pb.GetUploadLocsResponse, error)
func (*RequestProxy) HasChunks ¶
func (p *RequestProxy) HasChunks(_ context.Context, in *pb.HasChunksRequest) (*pb.HasChunksResponse, error)
func (*RequestProxy) ListTableFiles ¶
func (p *RequestProxy) ListTableFiles(ctx context.Context, in *pb.ListTableFilesRequest) (*pb.ListTableFilesResponse, error)
func (*RequestProxy) Rebase ¶
func (p *RequestProxy) Rebase(_ context.Context, in *pb.RebaseRequest) (*pb.RebaseResponse, error)
func (*RequestProxy) RefreshTableFileUrl ¶
func (p *RequestProxy) RefreshTableFileUrl(ctx context.Context, in *pb.RefreshTableFileUrlRequest) (*pb.RefreshTableFileUrlResponse, error)
func (*RequestProxy) Root ¶
func (p *RequestProxy) Root(_ context.Context, in *pb.RootRequest) (*pb.RootResponse, error)
func (*RequestProxy) ServeHTTP ¶
func (p *RequestProxy) ServeHTTP(writer http.ResponseWriter, request *http.Request)
func (*RequestProxy) Start ¶
func (p *RequestProxy) Start()
func (*RequestProxy) StreamDownloadLocations ¶
func (p *RequestProxy) StreamDownloadLocations(stream pb.ChunkStoreService_StreamDownloadLocationsServer) (err error)
type ResponseProxy ¶
type ResponseProxy struct {
// contains filtered or unexported fields
}
func NewResponseProxy ¶
func NewResponseProxy(config *config.ResponseProxyConfig) (*ResponseProxy, error)
func (*ResponseProxy) Close ¶
func (p *ResponseProxy) Close()
func (*ResponseProxy) Start ¶
func (p *ResponseProxy) Start()
type StreamDownloadLocationsClientEx ¶
type StreamDownloadLocationsClientEx struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.