natz

Documentation

Index

• Variables
• type NamespaceKvs
• type NatsConnConfiguration
• type NatsService
  • func NewNatsService(nc *NatsConnConfiguration) (*NatsService, error)
  • func (s *NatsService) KvsFor(ctx context.Context, ns string) (*NamespaceKvs, error)

Variables

var NatsConfig string

NatsConfig holds the current nats configuration for SHAR.

Types

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
	WfTracking        jetstream.KeyValue
	Job               jetstream.KeyValue
	OwnerName         jetstream.KeyValue
	OwnerID           jetstream.KeyValue
	WfClientTask      jetstream.KeyValue
	WfGateway         jetstream.KeyValue
	WfHistory         jetstream.KeyValue
	WfLock            jetstream.KeyValue
	WfMsgTypes        jetstream.KeyValue
	WfProcess         jetstream.KeyValue
	WfMessages        jetstream.KeyValue
	WfClients         jetstream.KeyValue
	WfFatalError      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

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

NewNatsService constructs a new NatsService

func (*NatsService) KvsFor

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

KvsFor retrieves the shar KVs for a given namespace. If they do not exist for a namespace, it will initialise them and store them in a map for future lookup.