natspb

package
v0.0.0-...-3a8d8de Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 9, 2025 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ObjectStoreScope_name = map[int32]string{
		0: "SCOPE_UNDEFINED",
		1: "SCOPE_WORKFLOW",
		2: "SCOPE_PROJECT",
	}
	ObjectStoreScope_value = map[string]int32{
		"SCOPE_UNDEFINED": 0,
		"SCOPE_WORKFLOW":  1,
		"SCOPE_PROJECT":   2,
	}
)

Enum value maps for ObjectStoreScope.

View Source 
var File_nats_proto protoreflect.FileDescriptor
View Source 
var NatsManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nats.NatsManagerService",
	HandlerType: (*NatsManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateStreams",
			Handler:    _NatsManagerService_CreateStreams_Handler,
		},
		{
			MethodName: "CreateObjectStores",
			Handler:    _NatsManagerService_CreateObjectStores_Handler,
		},
		{
			MethodName: "CreateVersionKeyValueStores",
			Handler:    _NatsManagerService_CreateVersionKeyValueStores_Handler,
		},
		{
			MethodName: "CreateGlobalKeyValueStore",
			Handler:    _NatsManagerService_CreateGlobalKeyValueStore_Handler,
		},
		{
			MethodName: "UpdateKeyValueConfiguration",
			Handler:    _NatsManagerService_UpdateKeyValueConfiguration_Handler,
		},
		{
			MethodName: "DeleteStreams",
			Handler:    _NatsManagerService_DeleteStreams_Handler,
		},
		{
			MethodName: "DeleteObjectStores",
			Handler:    _NatsManagerService_DeleteObjectStores_Handler,
		},
		{
			MethodName: "DeleteVersionKeyValueStores",
			Handler:    _NatsManagerService_DeleteVersionKeyValueStores_Handler,
		},
		{
			MethodName: "DeleteGlobalKeyValueStore",
			Handler:    _NatsManagerService_DeleteGlobalKeyValueStore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nats.proto",
}

NatsManagerService_ServiceDesc is the grpc.ServiceDesc for NatsManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterNatsManagerServiceServer 

func RegisterNatsManagerServiceServer(s grpc.ServiceRegistrar, srv NatsManagerServiceServer)

Types

type CreateGlobalKeyValueStoreRequest 

type CreateGlobalKeyValueStoreRequest struct {
	ProductId string `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateGlobalKeyValueStoreRequest) Descriptor deprecated 

func (*CreateGlobalKeyValueStoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateGlobalKeyValueStoreRequest.ProtoReflect.Descriptor instead.

func (*CreateGlobalKeyValueStoreRequest) GetProductId 

func (x *CreateGlobalKeyValueStoreRequest) GetProductId() string

func (*CreateGlobalKeyValueStoreRequest) ProtoMessage 

func (*CreateGlobalKeyValueStoreRequest) ProtoMessage()

func (*CreateGlobalKeyValueStoreRequest) ProtoReflect 

func (x *CreateGlobalKeyValueStoreRequest) ProtoReflect() protoreflect.Message

func (*CreateGlobalKeyValueStoreRequest) Reset 

func (x *CreateGlobalKeyValueStoreRequest) Reset()

func (*CreateGlobalKeyValueStoreRequest) String 

func (x *CreateGlobalKeyValueStoreRequest) String() string

type CreateGlobalKeyValueStoreResponse 

type CreateGlobalKeyValueStoreResponse struct {
	GlobalKeyValueStore string `protobuf:"bytes,1,opt,name=global_key_value_store,json=globalKeyValueStore,proto3" json:"global_key_value_store,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateGlobalKeyValueStoreResponse) Descriptor deprecated 

func (*CreateGlobalKeyValueStoreResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateGlobalKeyValueStoreResponse.ProtoReflect.Descriptor instead.

func (*CreateGlobalKeyValueStoreResponse) GetGlobalKeyValueStore 

func (x *CreateGlobalKeyValueStoreResponse) GetGlobalKeyValueStore() string

func (*CreateGlobalKeyValueStoreResponse) ProtoMessage 

func (*CreateGlobalKeyValueStoreResponse) ProtoMessage()

func (*CreateGlobalKeyValueStoreResponse) ProtoReflect 

func (x *CreateGlobalKeyValueStoreResponse) ProtoReflect() protoreflect.Message

func (*CreateGlobalKeyValueStoreResponse) Reset 

func (x *CreateGlobalKeyValueStoreResponse) Reset()

func (*CreateGlobalKeyValueStoreResponse) String 

func (x *CreateGlobalKeyValueStoreResponse) String() string

type CreateObjectStoresRequest 

type CreateObjectStoresRequest struct {
	ProductId  string      `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string      `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	Workflows  []*Workflow `protobuf:"bytes,3,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateObjectStoresRequest) Descriptor deprecated 

func (*CreateObjectStoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateObjectStoresRequest.ProtoReflect.Descriptor instead.

func (*CreateObjectStoresRequest) GetProductId 

func (x *CreateObjectStoresRequest) GetProductId() string

func (*CreateObjectStoresRequest) GetVersionTag 

func (x *CreateObjectStoresRequest) GetVersionTag() string

func (*CreateObjectStoresRequest) GetWorkflows 

func (x *CreateObjectStoresRequest) GetWorkflows() []*Workflow

func (*CreateObjectStoresRequest) ProtoMessage 

func (*CreateObjectStoresRequest) ProtoMessage()

func (*CreateObjectStoresRequest) ProtoReflect 

func (x *CreateObjectStoresRequest) ProtoReflect() protoreflect.Message

func (*CreateObjectStoresRequest) Reset 

func (x *CreateObjectStoresRequest) Reset()

func (*CreateObjectStoresRequest) String 

func (x *CreateObjectStoresRequest) String() string

type CreateObjectStoresResponse 

type CreateObjectStoresResponse struct {
	Workflows map[string]*WorkflowObjectStoreConfig `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateObjectStoresResponse) Descriptor deprecated 

func (*CreateObjectStoresResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateObjectStoresResponse.ProtoReflect.Descriptor instead.

func (*CreateObjectStoresResponse) GetWorkflows 

func (x *CreateObjectStoresResponse) GetWorkflows() map[string]*WorkflowObjectStoreConfig

func (*CreateObjectStoresResponse) ProtoMessage 

func (*CreateObjectStoresResponse) ProtoMessage()

func (*CreateObjectStoresResponse) ProtoReflect 

func (x *CreateObjectStoresResponse) ProtoReflect() protoreflect.Message

func (*CreateObjectStoresResponse) Reset 

func (x *CreateObjectStoresResponse) Reset()

func (*CreateObjectStoresResponse) String 

func (x *CreateObjectStoresResponse) String() string

type CreateStreamsRequest 

type CreateStreamsRequest struct {
	ProductId  string      `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string      `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	Workflows  []*Workflow `protobuf:"bytes,3,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamsRequest) Descriptor deprecated 

func (*CreateStreamsRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateStreamsRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamsRequest) GetProductId 

func (x *CreateStreamsRequest) GetProductId() string

func (*CreateStreamsRequest) GetVersionTag 

func (x *CreateStreamsRequest) GetVersionTag() string

func (*CreateStreamsRequest) GetWorkflows 

func (x *CreateStreamsRequest) GetWorkflows() []*Workflow

func (*CreateStreamsRequest) ProtoMessage 

func (*CreateStreamsRequest) ProtoMessage()

func (*CreateStreamsRequest) ProtoReflect 

func (x *CreateStreamsRequest) ProtoReflect() protoreflect.Message

func (*CreateStreamsRequest) Reset 

func (x *CreateStreamsRequest) Reset()

func (*CreateStreamsRequest) String 

func (x *CreateStreamsRequest) String() string

type CreateStreamsResponse 

type CreateStreamsResponse struct {
	Workflows map[string]*WorkflowStreamConfig `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateStreamsResponse) Descriptor deprecated 

func (*CreateStreamsResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateStreamsResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamsResponse) GetWorkflows 

func (x *CreateStreamsResponse) GetWorkflows() map[string]*WorkflowStreamConfig

func (*CreateStreamsResponse) ProtoMessage 

func (*CreateStreamsResponse) ProtoMessage()

func (*CreateStreamsResponse) ProtoReflect 

func (x *CreateStreamsResponse) ProtoReflect() protoreflect.Message

func (*CreateStreamsResponse) Reset 

func (x *CreateStreamsResponse) Reset()

func (*CreateStreamsResponse) String 

func (x *CreateStreamsResponse) String() string

type CreateVersionKeyValueStoresRequest 

type CreateVersionKeyValueStoresRequest struct {
	ProductId  string      `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string      `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	Workflows  []*Workflow `protobuf:"bytes,3,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVersionKeyValueStoresRequest) Descriptor deprecated 

func (*CreateVersionKeyValueStoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateVersionKeyValueStoresRequest.ProtoReflect.Descriptor instead.

func (*CreateVersionKeyValueStoresRequest) GetProductId 

func (x *CreateVersionKeyValueStoresRequest) GetProductId() string

func (*CreateVersionKeyValueStoresRequest) GetVersionTag 

func (x *CreateVersionKeyValueStoresRequest) GetVersionTag() string

func (*CreateVersionKeyValueStoresRequest) GetWorkflows 

func (x *CreateVersionKeyValueStoresRequest) GetWorkflows() []*Workflow

func (*CreateVersionKeyValueStoresRequest) ProtoMessage 

func (*CreateVersionKeyValueStoresRequest) ProtoMessage()

func (*CreateVersionKeyValueStoresRequest) ProtoReflect 

func (x *CreateVersionKeyValueStoresRequest) ProtoReflect() protoreflect.Message

func (*CreateVersionKeyValueStoresRequest) Reset 

func (x *CreateVersionKeyValueStoresRequest) Reset()

func (*CreateVersionKeyValueStoresRequest) String 

func (x *CreateVersionKeyValueStoresRequest) String() string

type CreateVersionKeyValueStoresResponse 

type CreateVersionKeyValueStoresResponse struct {
	KeyValueStore string                                  `protobuf:"bytes,1,opt,name=key_value_store,json=keyValueStore,proto3" json:"key_value_store,omitempty"`
	Workflows     map[string]*WorkflowKeyValueStoreConfig `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateVersionKeyValueStoresResponse) Descriptor deprecated 

func (*CreateVersionKeyValueStoresResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateVersionKeyValueStoresResponse.ProtoReflect.Descriptor instead.

func (*CreateVersionKeyValueStoresResponse) GetKeyValueStore 

func (x *CreateVersionKeyValueStoresResponse) GetKeyValueStore() string

func (*CreateVersionKeyValueStoresResponse) GetWorkflows 

func (x *CreateVersionKeyValueStoresResponse) GetWorkflows() map[string]*WorkflowKeyValueStoreConfig

func (*CreateVersionKeyValueStoresResponse) ProtoMessage 

func (*CreateVersionKeyValueStoresResponse) ProtoMessage()

func (*CreateVersionKeyValueStoresResponse) ProtoReflect 

func (x *CreateVersionKeyValueStoresResponse) ProtoReflect() protoreflect.Message

func (*CreateVersionKeyValueStoresResponse) Reset 

func (x *CreateVersionKeyValueStoresResponse) Reset()

func (*CreateVersionKeyValueStoresResponse) String 

func (x *CreateVersionKeyValueStoresResponse) String() string

type DeleteGlobalKeyValueStoreRequest 

type DeleteGlobalKeyValueStoreRequest struct {
	ProductId string `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteGlobalKeyValueStoreRequest) Descriptor deprecated 

func (*DeleteGlobalKeyValueStoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteGlobalKeyValueStoreRequest.ProtoReflect.Descriptor instead.

func (*DeleteGlobalKeyValueStoreRequest) GetProductId 

func (x *DeleteGlobalKeyValueStoreRequest) GetProductId() string

func (*DeleteGlobalKeyValueStoreRequest) ProtoMessage 

func (*DeleteGlobalKeyValueStoreRequest) ProtoMessage()

func (*DeleteGlobalKeyValueStoreRequest) ProtoReflect 

func (x *DeleteGlobalKeyValueStoreRequest) ProtoReflect() protoreflect.Message

func (*DeleteGlobalKeyValueStoreRequest) Reset 

func (x *DeleteGlobalKeyValueStoreRequest) Reset()

func (*DeleteGlobalKeyValueStoreRequest) String 

func (x *DeleteGlobalKeyValueStoreRequest) String() string

type DeleteObjectStoresRequest 

type DeleteObjectStoresRequest struct {
	ProductId  string `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectStoresRequest) Descriptor deprecated 

func (*DeleteObjectStoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteObjectStoresRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectStoresRequest) GetProductId 

func (x *DeleteObjectStoresRequest) GetProductId() string

func (*DeleteObjectStoresRequest) GetVersionTag 

func (x *DeleteObjectStoresRequest) GetVersionTag() string

func (*DeleteObjectStoresRequest) ProtoMessage 

func (*DeleteObjectStoresRequest) ProtoMessage()

func (*DeleteObjectStoresRequest) ProtoReflect 

func (x *DeleteObjectStoresRequest) ProtoReflect() protoreflect.Message

func (*DeleteObjectStoresRequest) Reset 

func (x *DeleteObjectStoresRequest) Reset()

func (*DeleteObjectStoresRequest) String 

func (x *DeleteObjectStoresRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

func (*DeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetMessage 

func (x *DeleteResponse) GetMessage() string

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteStreamsRequest 

type DeleteStreamsRequest struct {
	ProductId  string `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStreamsRequest) Descriptor deprecated 

func (*DeleteStreamsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStreamsRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamsRequest) GetProductId 

func (x *DeleteStreamsRequest) GetProductId() string

func (*DeleteStreamsRequest) GetVersionTag 

func (x *DeleteStreamsRequest) GetVersionTag() string

func (*DeleteStreamsRequest) ProtoMessage 

func (*DeleteStreamsRequest) ProtoMessage()

func (*DeleteStreamsRequest) ProtoReflect 

func (x *DeleteStreamsRequest) ProtoReflect() protoreflect.Message

func (*DeleteStreamsRequest) Reset 

func (x *DeleteStreamsRequest) Reset()

func (*DeleteStreamsRequest) String 

func (x *DeleteStreamsRequest) String() string

type DeleteVersionKeyValueStoresRequest 

type DeleteVersionKeyValueStoresRequest struct {
	ProductId  string      `protobuf:"bytes,1,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	VersionTag string      `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
	Workflows  []*Workflow `protobuf:"bytes,3,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVersionKeyValueStoresRequest) Descriptor deprecated 

func (*DeleteVersionKeyValueStoresRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVersionKeyValueStoresRequest.ProtoReflect.Descriptor instead.

func (*DeleteVersionKeyValueStoresRequest) GetProductId 

func (x *DeleteVersionKeyValueStoresRequest) GetProductId() string

func (*DeleteVersionKeyValueStoresRequest) GetVersionTag 

func (x *DeleteVersionKeyValueStoresRequest) GetVersionTag() string

func (*DeleteVersionKeyValueStoresRequest) GetWorkflows 

func (x *DeleteVersionKeyValueStoresRequest) GetWorkflows() []*Workflow

func (*DeleteVersionKeyValueStoresRequest) ProtoMessage 

func (*DeleteVersionKeyValueStoresRequest) ProtoMessage()

func (*DeleteVersionKeyValueStoresRequest) ProtoReflect 

func (x *DeleteVersionKeyValueStoresRequest) ProtoReflect() protoreflect.Message

func (*DeleteVersionKeyValueStoresRequest) Reset 

func (x *DeleteVersionKeyValueStoresRequest) Reset()

func (*DeleteVersionKeyValueStoresRequest) String 

func (x *DeleteVersionKeyValueStoresRequest) String() string

type KeyValueConfiguration 

type KeyValueConfiguration struct {
	KeyValueStore string            `protobuf:"bytes,1,opt,name=key_value_store,json=keyValueStore,proto3" json:"key_value_store,omitempty"`
	Configuration map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KeyValueConfiguration) Descriptor deprecated 

func (*KeyValueConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use KeyValueConfiguration.ProtoReflect.Descriptor instead.

func (*KeyValueConfiguration) GetConfiguration 

func (x *KeyValueConfiguration) GetConfiguration() map[string]string

func (*KeyValueConfiguration) GetKeyValueStore 

func (x *KeyValueConfiguration) GetKeyValueStore() string

func (*KeyValueConfiguration) ProtoMessage 

func (*KeyValueConfiguration) ProtoMessage()

func (*KeyValueConfiguration) ProtoReflect 

func (x *KeyValueConfiguration) ProtoReflect() protoreflect.Message

func (*KeyValueConfiguration) Reset 

func (x *KeyValueConfiguration) Reset()

func (*KeyValueConfiguration) String 

func (x *KeyValueConfiguration) String() string

type NatsManagerServiceClient 

type NatsManagerServiceClient interface {
	CreateStreams(ctx context.Context, in *CreateStreamsRequest, opts ...grpc.CallOption) (*CreateStreamsResponse, error)
	CreateObjectStores(ctx context.Context, in *CreateObjectStoresRequest, opts ...grpc.CallOption) (*CreateObjectStoresResponse, error)
	CreateVersionKeyValueStores(ctx context.Context, in *CreateVersionKeyValueStoresRequest, opts ...grpc.CallOption) (*CreateVersionKeyValueStoresResponse, error)
	CreateGlobalKeyValueStore(ctx context.Context, in *CreateGlobalKeyValueStoreRequest, opts ...grpc.CallOption) (*CreateGlobalKeyValueStoreResponse, error)
	UpdateKeyValueConfiguration(ctx context.Context, in *UpdateKeyValueConfigurationRequest, opts ...grpc.CallOption) (*UpdateKeyValueConfigurationResponse, error)
	DeleteStreams(ctx context.Context, in *DeleteStreamsRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteObjectStores(ctx context.Context, in *DeleteObjectStoresRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteVersionKeyValueStores(ctx context.Context, in *DeleteVersionKeyValueStoresRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteGlobalKeyValueStore(ctx context.Context, in *DeleteGlobalKeyValueStoreRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}

NatsManagerServiceClient is the client API for NatsManagerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNatsManagerServiceClient 

func NewNatsManagerServiceClient(cc grpc.ClientConnInterface) NatsManagerServiceClient

type NatsManagerServiceServer 

type NatsManagerServiceServer interface {
	CreateStreams(context.Context, *CreateStreamsRequest) (*CreateStreamsResponse, error)
	CreateObjectStores(context.Context, *CreateObjectStoresRequest) (*CreateObjectStoresResponse, error)
	CreateVersionKeyValueStores(context.Context, *CreateVersionKeyValueStoresRequest) (*CreateVersionKeyValueStoresResponse, error)
	CreateGlobalKeyValueStore(context.Context, *CreateGlobalKeyValueStoreRequest) (*CreateGlobalKeyValueStoreResponse, error)
	UpdateKeyValueConfiguration(context.Context, *UpdateKeyValueConfigurationRequest) (*UpdateKeyValueConfigurationResponse, error)
	DeleteStreams(context.Context, *DeleteStreamsRequest) (*DeleteResponse, error)
	DeleteObjectStores(context.Context, *DeleteObjectStoresRequest) (*DeleteResponse, error)
	DeleteVersionKeyValueStores(context.Context, *DeleteVersionKeyValueStoresRequest) (*DeleteResponse, error)
	DeleteGlobalKeyValueStore(context.Context, *DeleteGlobalKeyValueStoreRequest) (*DeleteResponse, error)
	// contains filtered or unexported methods
}

NatsManagerServiceServer is the server API for NatsManagerService service. All implementations must embed UnimplementedNatsManagerServiceServer for forward compatibility

type ObjectStore 

type ObjectStore struct {
	Name  string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Scope ObjectStoreScope `protobuf:"varint,2,opt,name=scope,proto3,enum=nats.ObjectStoreScope" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStore) Descriptor deprecated 

func (*ObjectStore) Descriptor() ([]byte, []int)

Deprecated: Use ObjectStore.ProtoReflect.Descriptor instead.

func (*ObjectStore) GetName 

func (x *ObjectStore) GetName() string

func (*ObjectStore) GetScope 

func (x *ObjectStore) GetScope() ObjectStoreScope

func (*ObjectStore) ProtoMessage 

func (*ObjectStore) ProtoMessage()

func (*ObjectStore) ProtoReflect 

func (x *ObjectStore) ProtoReflect() protoreflect.Message

func (*ObjectStore) Reset 

func (x *ObjectStore) Reset()

func (*ObjectStore) String 

func (x *ObjectStore) String() string

type ObjectStoreScope 

type ObjectStoreScope int32
const (
	ObjectStoreScope_SCOPE_UNDEFINED ObjectStoreScope = 0
	ObjectStoreScope_SCOPE_WORKFLOW  ObjectStoreScope = 1
	ObjectStoreScope_SCOPE_PROJECT   ObjectStoreScope = 2
)

func (ObjectStoreScope) Descriptor 

func (ObjectStoreScope) Descriptor() protoreflect.EnumDescriptor

func (ObjectStoreScope) Enum 

func (x ObjectStoreScope) Enum() *ObjectStoreScope

func (ObjectStoreScope) EnumDescriptor deprecated 

func (ObjectStoreScope) EnumDescriptor() ([]byte, []int)

Deprecated: Use ObjectStoreScope.Descriptor instead.

func (ObjectStoreScope) Number 

func (x ObjectStoreScope) Number() protoreflect.EnumNumber

func (ObjectStoreScope) String 

func (x ObjectStoreScope) String() string

func (ObjectStoreScope) Type 

func (ObjectStoreScope) Type() protoreflect.EnumType

type Process 

type Process struct {
	Name          string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Subscriptions []string     `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	ObjectStore   *ObjectStore `protobuf:"bytes,3,opt,name=object_store,json=objectStore,proto3,oneof" json:"object_store,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

func (*Process) Descriptor() ([]byte, []int)

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetName 

func (x *Process) GetName() string

func (*Process) GetObjectStore 

func (x *Process) GetObjectStore() *ObjectStore

func (*Process) GetSubscriptions 

func (x *Process) GetSubscriptions() []string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type ProcessStreamConfig 

type ProcessStreamConfig struct {
	Subject       string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Subscriptions []string `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessStreamConfig) Descriptor deprecated 

func (*ProcessStreamConfig) Descriptor() ([]byte, []int)

Deprecated: Use ProcessStreamConfig.ProtoReflect.Descriptor instead.

func (*ProcessStreamConfig) GetSubject 

func (x *ProcessStreamConfig) GetSubject() string

func (*ProcessStreamConfig) GetSubscriptions 

func (x *ProcessStreamConfig) GetSubscriptions() []string

func (*ProcessStreamConfig) ProtoMessage 

func (*ProcessStreamConfig) ProtoMessage()

func (*ProcessStreamConfig) ProtoReflect 

func (x *ProcessStreamConfig) ProtoReflect() protoreflect.Message

func (*ProcessStreamConfig) Reset 

func (x *ProcessStreamConfig) Reset()

func (*ProcessStreamConfig) String 

func (x *ProcessStreamConfig) String() string

type UnimplementedNatsManagerServiceServer 

type UnimplementedNatsManagerServiceServer struct {
}

UnimplementedNatsManagerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNatsManagerServiceServer) CreateGlobalKeyValueStore 

func (UnimplementedNatsManagerServiceServer) CreateGlobalKeyValueStore(context.Context, *CreateGlobalKeyValueStoreRequest) (*CreateGlobalKeyValueStoreResponse, error)

func (UnimplementedNatsManagerServiceServer) CreateObjectStores 

func (UnimplementedNatsManagerServiceServer) CreateObjectStores(context.Context, *CreateObjectStoresRequest) (*CreateObjectStoresResponse, error)

func (UnimplementedNatsManagerServiceServer) CreateStreams 

func (UnimplementedNatsManagerServiceServer) CreateStreams(context.Context, *CreateStreamsRequest) (*CreateStreamsResponse, error)

func (UnimplementedNatsManagerServiceServer) CreateVersionKeyValueStores 

func (UnimplementedNatsManagerServiceServer) CreateVersionKeyValueStores(context.Context, *CreateVersionKeyValueStoresRequest) (*CreateVersionKeyValueStoresResponse, error)

func (UnimplementedNatsManagerServiceServer) DeleteGlobalKeyValueStore 

func (UnimplementedNatsManagerServiceServer) DeleteGlobalKeyValueStore(context.Context, *DeleteGlobalKeyValueStoreRequest) (*DeleteResponse, error)

func (UnimplementedNatsManagerServiceServer) DeleteObjectStores 

func (UnimplementedNatsManagerServiceServer) DeleteObjectStores(context.Context, *DeleteObjectStoresRequest) (*DeleteResponse, error)

func (UnimplementedNatsManagerServiceServer) DeleteStreams 

func (UnimplementedNatsManagerServiceServer) DeleteStreams(context.Context, *DeleteStreamsRequest) (*DeleteResponse, error)

func (UnimplementedNatsManagerServiceServer) DeleteVersionKeyValueStores 

func (UnimplementedNatsManagerServiceServer) DeleteVersionKeyValueStores(context.Context, *DeleteVersionKeyValueStoresRequest) (*DeleteResponse, error)

func (UnimplementedNatsManagerServiceServer) UpdateKeyValueConfiguration 

func (UnimplementedNatsManagerServiceServer) UpdateKeyValueConfiguration(context.Context, *UpdateKeyValueConfigurationRequest) (*UpdateKeyValueConfigurationResponse, error)

type UnsafeNatsManagerServiceServer 

type UnsafeNatsManagerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNatsManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NatsManagerServiceServer will result in compilation errors.

type UpdateKeyValueConfigurationRequest 

type UpdateKeyValueConfigurationRequest struct {
	KeyValueStoresConfig []*KeyValueConfiguration `protobuf:"bytes,1,rep,name=key_value_stores_config,json=keyValueStoresConfig,proto3" json:"key_value_stores_config,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateKeyValueConfigurationRequest) Descriptor deprecated 

func (*UpdateKeyValueConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateKeyValueConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UpdateKeyValueConfigurationRequest) GetKeyValueStoresConfig 

func (x *UpdateKeyValueConfigurationRequest) GetKeyValueStoresConfig() []*KeyValueConfiguration

func (*UpdateKeyValueConfigurationRequest) ProtoMessage 

func (*UpdateKeyValueConfigurationRequest) ProtoMessage()

func (*UpdateKeyValueConfigurationRequest) ProtoReflect 

func (x *UpdateKeyValueConfigurationRequest) ProtoReflect() protoreflect.Message

func (*UpdateKeyValueConfigurationRequest) Reset 

func (x *UpdateKeyValueConfigurationRequest) Reset()

func (*UpdateKeyValueConfigurationRequest) String 

func (x *UpdateKeyValueConfigurationRequest) String() string

type UpdateKeyValueConfigurationResponse 

type UpdateKeyValueConfigurationResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateKeyValueConfigurationResponse) Descriptor deprecated 

func (*UpdateKeyValueConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateKeyValueConfigurationResponse.ProtoReflect.Descriptor instead.

func (*UpdateKeyValueConfigurationResponse) GetMessage 

func (x *UpdateKeyValueConfigurationResponse) GetMessage() string

func (*UpdateKeyValueConfigurationResponse) ProtoMessage 

func (*UpdateKeyValueConfigurationResponse) ProtoMessage()

func (*UpdateKeyValueConfigurationResponse) ProtoReflect 

func (x *UpdateKeyValueConfigurationResponse) ProtoReflect() protoreflect.Message

func (*UpdateKeyValueConfigurationResponse) Reset 

func (x *UpdateKeyValueConfigurationResponse) Reset()

func (*UpdateKeyValueConfigurationResponse) String 

func (x *UpdateKeyValueConfigurationResponse) String() string

type Workflow 

type Workflow struct {
	Name      string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Processes []*Process `protobuf:"bytes,2,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated 

func (*Workflow) Descriptor() ([]byte, []int)

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetName 

func (x *Workflow) GetName() string

func (*Workflow) GetProcesses 

func (x *Workflow) GetProcesses() []*Process

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

type WorkflowKeyValueStoreConfig 

type WorkflowKeyValueStoreConfig struct {
	KeyValueStore string            `protobuf:"bytes,1,opt,name=keyValueStore,proto3" json:"keyValueStore,omitempty"`
	Processes     map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowKeyValueStoreConfig) Descriptor deprecated 

func (*WorkflowKeyValueStoreConfig) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowKeyValueStoreConfig.ProtoReflect.Descriptor instead.

func (*WorkflowKeyValueStoreConfig) GetKeyValueStore 

func (x *WorkflowKeyValueStoreConfig) GetKeyValueStore() string

func (*WorkflowKeyValueStoreConfig) GetProcesses 

func (x *WorkflowKeyValueStoreConfig) GetProcesses() map[string]string

func (*WorkflowKeyValueStoreConfig) ProtoMessage 

func (*WorkflowKeyValueStoreConfig) ProtoMessage()

func (*WorkflowKeyValueStoreConfig) ProtoReflect 

func (x *WorkflowKeyValueStoreConfig) ProtoReflect() protoreflect.Message

func (*WorkflowKeyValueStoreConfig) Reset 

func (x *WorkflowKeyValueStoreConfig) Reset()

func (*WorkflowKeyValueStoreConfig) String 

func (x *WorkflowKeyValueStoreConfig) String() string

type WorkflowObjectStoreConfig 

type WorkflowObjectStoreConfig struct {
	Processes map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowObjectStoreConfig) Descriptor deprecated 

func (*WorkflowObjectStoreConfig) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowObjectStoreConfig.ProtoReflect.Descriptor instead.

func (*WorkflowObjectStoreConfig) GetProcesses 

func (x *WorkflowObjectStoreConfig) GetProcesses() map[string]string

func (*WorkflowObjectStoreConfig) ProtoMessage 

func (*WorkflowObjectStoreConfig) ProtoMessage()

func (*WorkflowObjectStoreConfig) ProtoReflect 

func (x *WorkflowObjectStoreConfig) ProtoReflect() protoreflect.Message

func (*WorkflowObjectStoreConfig) Reset 

func (x *WorkflowObjectStoreConfig) Reset()

func (*WorkflowObjectStoreConfig) String 

func (x *WorkflowObjectStoreConfig) String() string

type WorkflowStreamConfig 

type WorkflowStreamConfig struct {
	Stream    string                          `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Processes map[string]*ProcessStreamConfig `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowStreamConfig) Descriptor deprecated 

func (*WorkflowStreamConfig) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowStreamConfig.ProtoReflect.Descriptor instead.

func (*WorkflowStreamConfig) GetProcesses 

func (x *WorkflowStreamConfig) GetProcesses() map[string]*ProcessStreamConfig

func (*WorkflowStreamConfig) GetStream 

func (x *WorkflowStreamConfig) GetStream() string

func (*WorkflowStreamConfig) ProtoMessage 

func (*WorkflowStreamConfig) ProtoMessage()

func (*WorkflowStreamConfig) ProtoReflect 

func (x *WorkflowStreamConfig) ProtoReflect() protoreflect.Message

func (*WorkflowStreamConfig) Reset 

func (x *WorkflowStreamConfig) Reset()

func (*WorkflowStreamConfig) String 

func (x *WorkflowStreamConfig) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.