grpcio

Documentation

Index

• func NewServer(ctx context.Context, addr string, service *GatewayService, useAlts bool) error
• type GatewayService
  • func NewGatewayService(topicService *gateway.TopicService, etcdClient *clientv3.Client, ...) *GatewayService
  • func (s *GatewayService) Append(server v1.GatewayService_AppendServer) error
  • func (s *GatewayService) CreateSubscription(ctx context.Context, req *v1.CreateSubscriptionRequest) (*empty.Empty, error)
  • func (s *GatewayService) CreateTopic(ctx context.Context, req *v1.CreateTopicRequest) (*empty.Empty, error)
  • func (s *GatewayService) ListSubscriptions(_ context.Context, req *v1.ListSubscriptionsRequest) (res *v1.ListSubscriptionsResponse, err error)
  • func (s *GatewayService) ListTopics(_ context.Context, _ *v1.ListTopicsRequest) (*v1.ListTopicsResponse, error)
  • func (s *GatewayService) Tail(server v1.GatewayService_TailServer) (err error)

Functions

func NewServer

func NewServer(ctx context.Context, addr string, service *GatewayService, useAlts bool) error

Types

type GatewayService

type GatewayService struct {
	v1.UnimplementedGatewayServiceServer
	// contains filtered or unexported fields
}

func NewGatewayService

func NewGatewayService(
	topicService *gateway.TopicService,
	etcdClient *clientv3.Client,
	bqReaderService *bigquery.ReaderService,
) *GatewayService

func (*GatewayService) Append

func (s *GatewayService) Append(server v1.GatewayService_AppendServer) error

func (*GatewayService) CreateSubscription

func (s *GatewayService) CreateSubscription(ctx context.Context, req *v1.CreateSubscriptionRequest) (*empty.Empty, error)

func (*GatewayService) CreateTopic

func (s *GatewayService) CreateTopic(ctx context.Context, req *v1.CreateTopicRequest) (*empty.Empty, error)

func (*GatewayService) ListSubscriptions

func (s *GatewayService) ListSubscriptions(_ context.Context, req *v1.ListSubscriptionsRequest) (res *v1.ListSubscriptionsResponse, err error)

func (*GatewayService) ListTopics

func (s *GatewayService) ListTopics(_ context.Context, _ *v1.ListTopicsRequest) (*v1.ListTopicsResponse, error)

func (*GatewayService) Tail

func (s *GatewayService) Tail(server v1.GatewayService_TailServer) (err error)

Tail will attempt to stream and entire segment to the client. If the client disconnects, the segment will be released and the client will be disconnected. If the segment is on the buffer, and the buffer drops the segment the client will be disconnected. If the segment reaches EOF the client will be disconnected. It is expected that the client will open a new stream to continue reading.