pubsub

Documentation

Index

• type Service
  • func New(module *schema.Module, deployment key.Deployment, verbClient VerbClient, ...) (*Service, error)
  • func (s *Service) Consume(ctx context.Context) error
  • func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)
  • func (s *Service) PublishEvent(ctx context.Context, req *connect.Request[pubsubpb.PublishEventRequest]) (*connect.Response[pubsubpb.PublishEventResponse], error)
  • func (s *Service) ResetOffsetsOfSubscription(ctx context.Context, ...) (*connect.Response[pubsubpb.ResetOffsetsOfSubscriptionResponse], error)
• type VerbClient

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func New

func New(module *schema.Module, deployment key.Deployment, verbClient VerbClient, timelineClient *timelineclient.Client) (*Service, error)

func (*Service) Consume

func (s *Service) Consume(ctx context.Context) error

func (*Service) Ping

func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) PublishEvent

func (s *Service) PublishEvent(ctx context.Context, req *connect.Request[pubsubpb.PublishEventRequest]) (*connect.Response[pubsubpb.PublishEventResponse], error)

func (*Service) ResetOffsetsOfSubscription

func (s *Service) ResetOffsetsOfSubscription(ctx context.Context, req *connect.Request[pubsubpb.ResetOffsetsOfSubscriptionRequest]) (*connect.Response[pubsubpb.ResetOffsetsOfSubscriptionResponse], error)

type VerbClient

type VerbClient interface {
	Call(ctx context.Context, c *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
}