lease

Documentation

Index

• type Service
  • func New(ctx context.Context) *Service
  • func (s *Service) AcquireLease(ctx context.Context, ...) error
  • func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)
  • func (s *Service) StartServices(ctx context.Context) ([]rpc.Option, error)

Types

type Service

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

func New

func New(ctx context.Context) *Service

func (*Service) AcquireLease

func (s *Service) AcquireLease(ctx context.Context, stream *connect.BidiStream[ftllease.AcquireLeaseRequest, ftllease.AcquireLeaseResponse]) error

func (*Service) Ping

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

func (*Service) StartServices

func (s *Service) StartServices(ctx context.Context) ([]rpc.Option, error)