service

Documentation

Index

• type NatsService
  • func NewNatsService(logger logr.Logger, manager interfaces.NatsManager) *NatsService
  • func (n *NatsService) CreateGlobalKeyValueStore(_ context.Context, req *natspb.CreateGlobalKeyValueStoreRequest) (*natspb.CreateGlobalKeyValueStoreResponse, error)
  • func (n *NatsService) CreateObjectStores(_ context.Context, req *natspb.CreateObjectStoresRequest) (*natspb.CreateObjectStoresResponse, error)
  • func (n *NatsService) CreateStreams(_ context.Context, req *natspb.CreateStreamsRequest) (*natspb.CreateStreamsResponse, error)
  • func (n *NatsService) CreateVersionKeyValueStores(_ context.Context, req *natspb.CreateVersionKeyValueStoresRequest) (*natspb.CreateVersionKeyValueStoresResponse, error)
  • func (n *NatsService) DeleteGlobalKeyValueStore(_ context.Context, req *natspb.DeleteGlobalKeyValueStoreRequest) (*natspb.DeleteResponse, error)
  • func (n *NatsService) DeleteObjectStores(_ context.Context, req *natspb.DeleteObjectStoresRequest) (*natspb.DeleteResponse, error)
  • func (n *NatsService) DeleteStreams(_ context.Context, req *natspb.DeleteStreamsRequest) (*natspb.DeleteResponse, error)
  • func (n *NatsService) DeleteVersionKeyValueStores(_ context.Context, req *natspb.DeleteVersionKeyValueStoresRequest) (*natspb.DeleteResponse, error)
  • func (n *NatsService) UpdateKeyValueConfiguration(_ context.Context, req *natspb.UpdateKeyValueConfigurationRequest) (*natspb.UpdateKeyValueConfigurationResponse, error)

Types

type NatsService

type NatsService struct {
	natspb.UnimplementedNatsManagerServiceServer
	// contains filtered or unexported fields
}

NatsService basic server.

func NewNatsService

func NewNatsService(
	logger logr.Logger,
	manager interfaces.NatsManager,
) *NatsService

NewNatsService instantiates the GRPC server implementation.

func (*NatsService) CreateGlobalKeyValueStore

func (n *NatsService) CreateGlobalKeyValueStore(
	_ context.Context,
	req *natspb.CreateGlobalKeyValueStoreRequest,
) (*natspb.CreateGlobalKeyValueStoreResponse, error)

func (*NatsService) CreateObjectStores

func (n *NatsService) CreateObjectStores(
	_ context.Context,
	req *natspb.CreateObjectStoresRequest,
) (*natspb.CreateObjectStoresResponse, error)

CreateObjectStores creates object stores for given workflows.

func (*NatsService) CreateStreams

func (n *NatsService) CreateStreams(
	_ context.Context,
	req *natspb.CreateStreamsRequest,
) (*natspb.CreateStreamsResponse, error)

CreateStreams create streams for given workflows.

func (*NatsService) CreateVersionKeyValueStores

func (n *NatsService) CreateVersionKeyValueStores(
	_ context.Context,
	req *natspb.CreateVersionKeyValueStoresRequest,
) (*natspb.CreateVersionKeyValueStoresResponse, error)

func (*NatsService) DeleteGlobalKeyValueStore

func (n *NatsService) DeleteGlobalKeyValueStore(
	_ context.Context,
	req *natspb.DeleteGlobalKeyValueStoreRequest,
) (*natspb.DeleteResponse, error)

func (*NatsService) DeleteObjectStores

func (n *NatsService) DeleteObjectStores(
	_ context.Context,
	req *natspb.DeleteObjectStoresRequest,
) (*natspb.DeleteResponse, error)

DeleteObjectStores delete object stores for given workflows.

func (*NatsService) DeleteStreams

func (n *NatsService) DeleteStreams(
	_ context.Context,
	req *natspb.DeleteStreamsRequest,
) (*natspb.DeleteResponse, error)

DeleteStreams delete streams for given workflows.

func (*NatsService) DeleteVersionKeyValueStores

func (n *NatsService) DeleteVersionKeyValueStores(
	_ context.Context,
	req *natspb.DeleteVersionKeyValueStoresRequest,
) (*natspb.DeleteResponse, error)

func (*NatsService) UpdateKeyValueConfiguration

func (n *NatsService) UpdateKeyValueConfiguration(
	_ context.Context,
	req *natspb.UpdateKeyValueConfigurationRequest,
) (*natspb.UpdateKeyValueConfigurationResponse, error)