pubsub

Documentation

Index

• type Service
  • func New(module *schema.Module, deployment model.DeploymentKey, 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[pb.PublishEventRequest]) (*connect.Response[pb.PublishEventResponse], error)
• type VerbClient

Types

type Service

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

func New

func New(module *schema.Module, deployment model.DeploymentKey, verbClient VerbClient, timelineClient *timeline.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[pb.PublishEventRequest]) (*connect.Response[pb.PublishEventResponse], error)

type VerbClient

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