natz

type MockPublishOpt ¶ added in v1.1.1687

type MockPublishOpt struct {
	mock.Mock
}

MockPublishOpt is an autogenerated mock type for the PublishOpt type

func NewMockPublishOpt(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockPublishOpt

func (_m *MockPublishOpt) Apply(n *PublishOptions)

func (_m *MockPublishOpt) EXPECT() *MockPublishOpt_Expecter

type MockPublishOpt_Apply_Call ¶ added in v1.1.1687

type MockPublishOpt_Apply_Call struct {
	*mock.Call
}

MockPublishOpt_Apply_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Apply'

func (_c *MockPublishOpt_Apply_Call) Return() *MockPublishOpt_Apply_Call

func (_c *MockPublishOpt_Apply_Call) Run(run func(n *PublishOptions)) *MockPublishOpt_Apply_Call

func (_c *MockPublishOpt_Apply_Call) RunAndReturn(run func(*PublishOptions)) *MockPublishOpt_Apply_Call

type MockPublishOpt_Expecter ¶ added in v1.1.1687

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

func (_e *MockPublishOpt_Expecter) Apply(n interface{}) *MockPublishOpt_Apply_Call

type NamespaceKvs ¶

type NamespaceKvs struct {
	WfExecution       jetstream.KeyValue
	WfProcessInstance jetstream.KeyValue
	WfUserTasks       jetstream.KeyValue
	WfTaskSpec        jetstream.KeyValue
	WfTaskSpecVer     jetstream.KeyValue
	Wf                jetstream.KeyValue
	WfVersion         jetstream.KeyValue
	WfTelemetry       jetstream.KeyValue
	Job               jetstream.KeyValue
	OwnerName         jetstream.KeyValue
	OwnerID           jetstream.KeyValue
	WfClientTask      jetstream.KeyValue
	WfGateway         jetstream.KeyValue
	//REM: WfHistory         jetstream.KeyValue
	WfLock          jetstream.KeyValue
	WfMsgTypes      jetstream.KeyValue
	WfProcess       jetstream.KeyValue
	WfMessages      jetstream.KeyValue
	WfClients       jetstream.KeyValue
	WfFatalError    jetstream.KeyValue
	WfUserTaskState jetstream.KeyValue
}

NamespaceKvs defines all the key value stores shar needs to operate

type NatsConnConfiguration ¶

type NatsConnConfiguration struct {
	Conn            *nats.Conn
	TxConn          *nats.Conn
	StorageType     jetstream.StorageType
	JetStreamDomain string
}

NatsConnConfiguration represents the configuration for a NATS connection.

- Conn: The NATS connection. - TxConn: The transactional NATS connection. - StorageType: The storage type for JetStream.

type NatsService ¶

type NatsService struct {
	Js   jetstream.JetStream
	TxJS jetstream.JetStream
	Conn common.NatsConn

	StorageType jetstream.StorageType

	Rwmx sync.RWMutex
	// contains filtered or unexported fields
}

NatsService contains items enabling nats related communications e.g. publish, nats object manipulation via jetstream and namespaced KV access.

func NewNatsService(nc *NatsConnConfiguration) (*NatsService, error)

func (s *NatsService) KvsFor(ctx context.Context, ns string) (*NamespaceKvs, error)

func (ns *NatsService) PublishMsg(ctx context.Context, subject string, sharMsg proto.Message) error

func (ns *NatsService) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, opts ...PublishOpt) error

type PublishOpt ¶ added in v1.1.1687

type PublishOpt interface {
	Apply(n *PublishOptions)
}

PublishOpt represents an option that can be used when publishing a workflow state

type PublishOptions ¶ added in v1.1.1687

type PublishOptions struct {
	Embargo int
	ID      string
	// contains filtered or unexported fields
}

PublishOptions represents all options that are changeable when publishing workflow state