services

Documentation

Index

• type NatsClientProvider
  • func NewNatsClientProvider(log *zap.Logger, js nats.JetStreamContext, storageType nats.StorageType) (*NatsClientProvider, error)
  • func (s *NatsClientProvider) GetJob(_ context.Context, id string) (*model.WorkflowState, error)
• type Storage

Types

type NatsClientProvider

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

func NewNatsClientProvider

func NewNatsClientProvider(log *zap.Logger, js nats.JetStreamContext, storageType nats.StorageType) (*NatsClientProvider, error)

func (*NatsClientProvider) GetJob

func (s *NatsClientProvider) GetJob(_ context.Context, id string) (*model.WorkflowState, error)

type Storage

type Storage interface {
	GetJob(ctx context.Context, id string) (*model.WorkflowState, error)
}