v1

package
v0.21.0 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2022 License: Apache-2.0 Imports: 22 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ResourceType_name = map[int32]string{
		0: "Api",
		1: "Function",
		2: "Bucket",
		3: "Queue",
		4: "Topic",
		5: "Schedule",
		6: "Subscription",
		7: "Collection",
		8: "Policy",
		9: "Secret",
	}
	ResourceType_value = map[string]int32{
		"Api":          0,
		"Function":     1,
		"Bucket":       2,
		"Queue":        3,
		"Topic":        4,
		"Schedule":     5,
		"Subscription": 6,
		"Collection":   7,
		"Policy":       8,
		"Secret":       9,
	}
)

Enum value maps for ResourceType.

View Source
var (
	Action_name = map[int32]string{
		0:   "BucketFileList",
		1:   "BucketFileGet",
		2:   "BucketFilePut",
		3:   "BucketFileDelete",
		200: "TopicList",
		201: "TopicDetail",
		202: "TopicEventPublish",
		300: "QueueSend",
		301: "QueueReceive",
		302: "QueueList",
		303: "QueueDetail",
		400: "CollectionDocumentRead",
		401: "CollectionDocumentWrite",
		402: "CollectionDocumentDelete",
		403: "CollectionQuery",
		404: "CollectionList",
		500: "SecretPut",
		501: "SecretAccess",
	}
	Action_value = map[string]int32{
		"BucketFileList":           0,
		"BucketFileGet":            1,
		"BucketFilePut":            2,
		"BucketFileDelete":         3,
		"TopicList":                200,
		"TopicDetail":              201,
		"TopicEventPublish":        202,
		"QueueSend":                300,
		"QueueReceive":             301,
		"QueueList":                302,
		"QueueDetail":              303,
		"CollectionDocumentRead":   400,
		"CollectionDocumentWrite":  401,
		"CollectionDocumentDelete": 402,
		"CollectionQuery":          403,
		"CollectionList":           404,
		"SecretPut":                500,
		"SecretAccess":             501,
	}
)

Enum value maps for Action.

View Source
var (
	StoragePreSignUrlRequest_Operation_name = map[int32]string{
		0: "READ",
		1: "WRITE",
	}
	StoragePreSignUrlRequest_Operation_value = map[string]int32{
		"READ":  0,
		"WRITE": 1,
	}
)

Enum value maps for StoragePreSignUrlRequest_Operation.

View Source
var DocumentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.document.v1.DocumentService",
	HandlerType: (*DocumentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _DocumentService_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _DocumentService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _DocumentService_Delete_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _DocumentService_Query_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "QueryStream",
			Handler:       _DocumentService_QueryStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "document/v1/document.proto",
}

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

View Source
var EventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.event.v1.EventService",
	HandlerType: (*EventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _EventService_Publish_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "event/v1/event.proto",
}

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

View Source
var FaasService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.faas.v1.FaasService",
	HandlerType: (*FaasServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TriggerStream",
			Handler:       _FaasService_TriggerStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "faas/v1/faas.proto",
}

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

View Source
var File_document_v1_document_proto protoreflect.FileDescriptor
View Source
var File_error_v1_error_proto protoreflect.FileDescriptor
View Source
var File_event_v1_event_proto protoreflect.FileDescriptor
View Source
var File_faas_v1_faas_proto protoreflect.FileDescriptor
View Source
var File_queue_v1_queue_proto protoreflect.FileDescriptor
View Source
var File_resource_v1_resource_proto protoreflect.FileDescriptor
View Source
var File_secret_v1_secret_proto protoreflect.FileDescriptor
View Source
var File_storage_v1_storage_proto protoreflect.FileDescriptor
View Source
var QueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.queue.v1.QueueService",
	HandlerType: (*QueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _QueueService_Send_Handler,
		},
		{
			MethodName: "SendBatch",
			Handler:    _QueueService_SendBatch_Handler,
		},
		{
			MethodName: "Receive",
			Handler:    _QueueService_Receive_Handler,
		},
		{
			MethodName: "Complete",
			Handler:    _QueueService_Complete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "queue/v1/queue.proto",
}

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

View Source
var ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.resource.v1.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Declare",
			Handler:    _ResourceService_Declare_Handler,
		},
		{
			MethodName: "Details",
			Handler:    _ResourceService_Details_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "resource/v1/resource.proto",
}

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

View Source
var SecretService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.secret.v1.SecretService",
	HandlerType: (*SecretServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _SecretService_Put_Handler,
		},
		{
			MethodName: "Access",
			Handler:    _SecretService_Access_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "secret/v1/secret.proto",
}

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

View Source
var StorageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.storage.v1.StorageService",
	HandlerType: (*StorageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Read",
			Handler:    _StorageService_Read_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _StorageService_Write_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _StorageService_Delete_Handler,
		},
		{
			MethodName: "PreSignUrl",
			Handler:    _StorageService_PreSignUrl_Handler,
		},
		{
			MethodName: "ListFiles",
			Handler:    _StorageService_ListFiles_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "storage/v1/storage.proto",
}

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

View Source
var TopicService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nitric.event.v1.TopicService",
	HandlerType: (*TopicServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _TopicService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "event/v1/event.proto",
}

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

Functions

func RegisterDocumentServiceServer

func RegisterDocumentServiceServer(s grpc.ServiceRegistrar, srv DocumentServiceServer)

func RegisterEventServiceServer

func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

func RegisterFaasServiceServer

func RegisterFaasServiceServer(s grpc.ServiceRegistrar, srv FaasServiceServer)

func RegisterQueueServiceServer

func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)

func RegisterResourceServiceServer

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

func RegisterSecretServiceServer

func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

func RegisterStorageServiceServer

func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)

func RegisterTopicServiceServer

func RegisterTopicServiceServer(s grpc.ServiceRegistrar, srv TopicServiceServer)

Types

type Action

type Action int32
const (
	// Bucket Permissions: 0XX
	Action_BucketFileList   Action = 0
	Action_BucketFileGet    Action = 1
	Action_BucketFilePut    Action = 2
	Action_BucketFileDelete Action = 3
	// Topic Permissions: 2XX
	Action_TopicList         Action = 200
	Action_TopicDetail       Action = 201
	Action_TopicEventPublish Action = 202
	// Queue Permissions: 3XX
	Action_QueueSend    Action = 300
	Action_QueueReceive Action = 301
	Action_QueueList    Action = 302
	Action_QueueDetail  Action = 303
	// Collection Permissions: 4XX
	Action_CollectionDocumentRead   Action = 400
	Action_CollectionDocumentWrite  Action = 401
	Action_CollectionDocumentDelete Action = 402
	Action_CollectionQuery          Action = 403
	Action_CollectionList           Action = 404
	// Secret Permissions: 5XX
	Action_SecretPut    Action = 500
	Action_SecretAccess Action = 501
)

func (Action) Descriptor

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number

func (x Action) Number() protoreflect.EnumNumber

func (Action) String

func (x Action) String() string

func (Action) Type

func (Action) Type() protoreflect.EnumType

type ApiResource added in v0.17.0

type ApiResource struct {

	// Security definitions for the api
	// These may be used by registered routes and operations on the API
	SecurityDefinitions map[string]*ApiSecurityDefinition `` /* 206-byte string literal not displayed */
	// root level security for this api
	Security map[string]*ApiScopes `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApiResource) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiResource.ProtoReflect.Descriptor instead.

func (*ApiResource) GetSecurity added in v0.17.0

func (x *ApiResource) GetSecurity() map[string]*ApiScopes

func (*ApiResource) GetSecurityDefinitions added in v0.17.0

func (x *ApiResource) GetSecurityDefinitions() map[string]*ApiSecurityDefinition

func (*ApiResource) ProtoMessage added in v0.17.0

func (*ApiResource) ProtoMessage()

func (*ApiResource) ProtoReflect added in v0.17.0

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

func (*ApiResource) Reset added in v0.17.0

func (x *ApiResource) Reset()

func (*ApiResource) String added in v0.17.0

func (x *ApiResource) String() string

func (*ApiResource) Validate added in v0.17.0

func (m *ApiResource) Validate() error

Validate checks the field values on ApiResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiResource) ValidateAll added in v0.17.0

func (m *ApiResource) ValidateAll() error

ValidateAll checks the field values on ApiResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiResourceMultiError, or nil if none found.

type ApiResourceDetails added in v0.20.0

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

func (*ApiResourceDetails) Descriptor deprecated added in v0.20.0

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

Deprecated: Use ApiResourceDetails.ProtoReflect.Descriptor instead.

func (*ApiResourceDetails) GetUrl added in v0.20.0

func (x *ApiResourceDetails) GetUrl() string

func (*ApiResourceDetails) ProtoMessage added in v0.20.0

func (*ApiResourceDetails) ProtoMessage()

func (*ApiResourceDetails) ProtoReflect added in v0.20.0

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

func (*ApiResourceDetails) Reset added in v0.20.0

func (x *ApiResourceDetails) Reset()

func (*ApiResourceDetails) String added in v0.20.0

func (x *ApiResourceDetails) String() string

func (*ApiResourceDetails) Validate added in v0.20.0

func (m *ApiResourceDetails) Validate() error

Validate checks the field values on ApiResourceDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiResourceDetails) ValidateAll added in v0.20.0

func (m *ApiResourceDetails) ValidateAll() error

ValidateAll checks the field values on ApiResourceDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiResourceDetailsMultiError, or nil if none found.

type ApiResourceDetailsMultiError added in v0.20.0

type ApiResourceDetailsMultiError []error

ApiResourceDetailsMultiError is an error wrapping multiple validation errors returned by ApiResourceDetails.ValidateAll() if the designated constraints aren't met.

func (ApiResourceDetailsMultiError) AllErrors added in v0.20.0

func (m ApiResourceDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiResourceDetailsMultiError) Error added in v0.20.0

Error returns a concatenation of all the error messages it wraps.

type ApiResourceDetailsValidationError added in v0.20.0

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

ApiResourceDetailsValidationError is the validation error returned by ApiResourceDetails.Validate if the designated constraints aren't met.

func (ApiResourceDetailsValidationError) Cause added in v0.20.0

Cause function returns cause value.

func (ApiResourceDetailsValidationError) Error added in v0.20.0

Error satisfies the builtin error interface

func (ApiResourceDetailsValidationError) ErrorName added in v0.20.0

ErrorName returns error name.

func (ApiResourceDetailsValidationError) Field added in v0.20.0

Field function returns field value.

func (ApiResourceDetailsValidationError) Key added in v0.20.0

Key function returns key value.

func (ApiResourceDetailsValidationError) Reason added in v0.20.0

Reason function returns reason value.

type ApiResourceMultiError added in v0.17.0

type ApiResourceMultiError []error

ApiResourceMultiError is an error wrapping multiple validation errors returned by ApiResource.ValidateAll() if the designated constraints aren't met.

func (ApiResourceMultiError) AllErrors added in v0.17.0

func (m ApiResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiResourceMultiError) Error added in v0.17.0

func (m ApiResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApiResourceValidationError added in v0.17.0

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

ApiResourceValidationError is the validation error returned by ApiResource.Validate if the designated constraints aren't met.

func (ApiResourceValidationError) Cause added in v0.17.0

Cause function returns cause value.

func (ApiResourceValidationError) Error added in v0.17.0

Error satisfies the builtin error interface

func (ApiResourceValidationError) ErrorName added in v0.17.0

func (e ApiResourceValidationError) ErrorName() string

ErrorName returns error name.

func (ApiResourceValidationError) Field added in v0.17.0

Field function returns field value.

func (ApiResourceValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiResourceValidationError) Reason added in v0.17.0

Reason function returns reason value.

type ApiScopes added in v0.17.0

type ApiScopes struct {
	Scopes []string `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiScopes) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiScopes.ProtoReflect.Descriptor instead.

func (*ApiScopes) GetScopes added in v0.17.0

func (x *ApiScopes) GetScopes() []string

func (*ApiScopes) ProtoMessage added in v0.17.0

func (*ApiScopes) ProtoMessage()

func (*ApiScopes) ProtoReflect added in v0.17.0

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

func (*ApiScopes) Reset added in v0.17.0

func (x *ApiScopes) Reset()

func (*ApiScopes) String added in v0.17.0

func (x *ApiScopes) String() string

func (*ApiScopes) Validate added in v0.17.0

func (m *ApiScopes) Validate() error

Validate checks the field values on ApiScopes with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiScopes) ValidateAll added in v0.17.0

func (m *ApiScopes) ValidateAll() error

ValidateAll checks the field values on ApiScopes with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiScopesMultiError, or nil if none found.

type ApiScopesMultiError added in v0.17.0

type ApiScopesMultiError []error

ApiScopesMultiError is an error wrapping multiple validation errors returned by ApiScopes.ValidateAll() if the designated constraints aren't met.

func (ApiScopesMultiError) AllErrors added in v0.17.0

func (m ApiScopesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiScopesMultiError) Error added in v0.17.0

func (m ApiScopesMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApiScopesValidationError added in v0.17.0

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

ApiScopesValidationError is the validation error returned by ApiScopes.Validate if the designated constraints aren't met.

func (ApiScopesValidationError) Cause added in v0.17.0

func (e ApiScopesValidationError) Cause() error

Cause function returns cause value.

func (ApiScopesValidationError) Error added in v0.17.0

func (e ApiScopesValidationError) Error() string

Error satisfies the builtin error interface

func (ApiScopesValidationError) ErrorName added in v0.17.0

func (e ApiScopesValidationError) ErrorName() string

ErrorName returns error name.

func (ApiScopesValidationError) Field added in v0.17.0

func (e ApiScopesValidationError) Field() string

Field function returns field value.

func (ApiScopesValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiScopesValidationError) Reason added in v0.17.0

func (e ApiScopesValidationError) Reason() string

Reason function returns reason value.

type ApiSecurityDefinition added in v0.17.0

type ApiSecurityDefinition struct {

	// Types that are assignable to Definition:
	//
	//	*ApiSecurityDefinition_Jwt
	Definition isApiSecurityDefinition_Definition `protobuf_oneof:"definition"`
	// contains filtered or unexported fields
}

func (*ApiSecurityDefinition) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiSecurityDefinition.ProtoReflect.Descriptor instead.

func (*ApiSecurityDefinition) GetDefinition added in v0.17.0

func (m *ApiSecurityDefinition) GetDefinition() isApiSecurityDefinition_Definition

func (*ApiSecurityDefinition) GetJwt added in v0.17.0

func (*ApiSecurityDefinition) ProtoMessage added in v0.17.0

func (*ApiSecurityDefinition) ProtoMessage()

func (*ApiSecurityDefinition) ProtoReflect added in v0.17.0

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

func (*ApiSecurityDefinition) Reset added in v0.17.0

func (x *ApiSecurityDefinition) Reset()

func (*ApiSecurityDefinition) String added in v0.17.0

func (x *ApiSecurityDefinition) String() string

func (*ApiSecurityDefinition) Validate added in v0.17.0

func (m *ApiSecurityDefinition) Validate() error

Validate checks the field values on ApiSecurityDefinition with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiSecurityDefinition) ValidateAll added in v0.17.0

func (m *ApiSecurityDefinition) ValidateAll() error

ValidateAll checks the field values on ApiSecurityDefinition with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiSecurityDefinitionMultiError, or nil if none found.

type ApiSecurityDefinitionJwt added in v0.17.0

type ApiSecurityDefinitionJwt struct {
	Issuer    string   `protobuf:"bytes,1,opt,name=issuer,proto3" json:"issuer,omitempty"`
	Audiences []string `protobuf:"bytes,2,rep,name=audiences,proto3" json:"audiences,omitempty"`
	// contains filtered or unexported fields
}

protect your API with JWT authentication

func (*ApiSecurityDefinitionJwt) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiSecurityDefinitionJwt.ProtoReflect.Descriptor instead.

func (*ApiSecurityDefinitionJwt) GetAudiences added in v0.17.0

func (x *ApiSecurityDefinitionJwt) GetAudiences() []string

func (*ApiSecurityDefinitionJwt) GetIssuer added in v0.17.0

func (x *ApiSecurityDefinitionJwt) GetIssuer() string

func (*ApiSecurityDefinitionJwt) ProtoMessage added in v0.17.0

func (*ApiSecurityDefinitionJwt) ProtoMessage()

func (*ApiSecurityDefinitionJwt) ProtoReflect added in v0.17.0

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

func (*ApiSecurityDefinitionJwt) Reset added in v0.17.0

func (x *ApiSecurityDefinitionJwt) Reset()

func (*ApiSecurityDefinitionJwt) String added in v0.17.0

func (x *ApiSecurityDefinitionJwt) String() string

func (*ApiSecurityDefinitionJwt) Validate added in v0.17.0

func (m *ApiSecurityDefinitionJwt) Validate() error

Validate checks the field values on ApiSecurityDefinitionJwt with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiSecurityDefinitionJwt) ValidateAll added in v0.17.0

func (m *ApiSecurityDefinitionJwt) ValidateAll() error

ValidateAll checks the field values on ApiSecurityDefinitionJwt with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiSecurityDefinitionJwtMultiError, or nil if none found.

type ApiSecurityDefinitionJwtMultiError added in v0.17.0

type ApiSecurityDefinitionJwtMultiError []error

ApiSecurityDefinitionJwtMultiError is an error wrapping multiple validation errors returned by ApiSecurityDefinitionJwt.ValidateAll() if the designated constraints aren't met.

func (ApiSecurityDefinitionJwtMultiError) AllErrors added in v0.17.0

func (m ApiSecurityDefinitionJwtMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiSecurityDefinitionJwtMultiError) Error added in v0.17.0

Error returns a concatenation of all the error messages it wraps.

type ApiSecurityDefinitionJwtValidationError added in v0.17.0

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

ApiSecurityDefinitionJwtValidationError is the validation error returned by ApiSecurityDefinitionJwt.Validate if the designated constraints aren't met.

func (ApiSecurityDefinitionJwtValidationError) Cause added in v0.17.0

Cause function returns cause value.

func (ApiSecurityDefinitionJwtValidationError) Error added in v0.17.0

Error satisfies the builtin error interface

func (ApiSecurityDefinitionJwtValidationError) ErrorName added in v0.17.0

ErrorName returns error name.

func (ApiSecurityDefinitionJwtValidationError) Field added in v0.17.0

Field function returns field value.

func (ApiSecurityDefinitionJwtValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiSecurityDefinitionJwtValidationError) Reason added in v0.17.0

Reason function returns reason value.

type ApiSecurityDefinitionMultiError added in v0.17.0

type ApiSecurityDefinitionMultiError []error

ApiSecurityDefinitionMultiError is an error wrapping multiple validation errors returned by ApiSecurityDefinition.ValidateAll() if the designated constraints aren't met.

func (ApiSecurityDefinitionMultiError) AllErrors added in v0.17.0

func (m ApiSecurityDefinitionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiSecurityDefinitionMultiError) Error added in v0.17.0

Error returns a concatenation of all the error messages it wraps.

type ApiSecurityDefinitionValidationError added in v0.17.0

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

ApiSecurityDefinitionValidationError is the validation error returned by ApiSecurityDefinition.Validate if the designated constraints aren't met.

func (ApiSecurityDefinitionValidationError) Cause added in v0.17.0

Cause function returns cause value.

func (ApiSecurityDefinitionValidationError) Error added in v0.17.0

Error satisfies the builtin error interface

func (ApiSecurityDefinitionValidationError) ErrorName added in v0.17.0

ErrorName returns error name.

func (ApiSecurityDefinitionValidationError) Field added in v0.17.0

Field function returns field value.

func (ApiSecurityDefinitionValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiSecurityDefinitionValidationError) Reason added in v0.17.0

Reason function returns reason value.

type ApiSecurityDefinition_Jwt added in v0.17.0

type ApiSecurityDefinition_Jwt struct {
	Jwt *ApiSecurityDefinitionJwt `protobuf:"bytes,1,opt,name=jwt,proto3,oneof"`
}

type ApiWorker

type ApiWorker struct {
	Api     string            `protobuf:"bytes,1,opt,name=api,proto3" json:"api,omitempty"`
	Path    string            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Methods []string          `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"`
	Options *ApiWorkerOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiWorker) Descriptor deprecated

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

Deprecated: Use ApiWorker.ProtoReflect.Descriptor instead.

func (*ApiWorker) GetApi

func (x *ApiWorker) GetApi() string

func (*ApiWorker) GetMethods

func (x *ApiWorker) GetMethods() []string

func (*ApiWorker) GetOptions added in v0.17.0

func (x *ApiWorker) GetOptions() *ApiWorkerOptions

func (*ApiWorker) GetPath

func (x *ApiWorker) GetPath() string

func (*ApiWorker) ProtoMessage

func (*ApiWorker) ProtoMessage()

func (*ApiWorker) ProtoReflect

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

func (*ApiWorker) Reset

func (x *ApiWorker) Reset()

func (*ApiWorker) String

func (x *ApiWorker) String() string

func (*ApiWorker) Validate

func (m *ApiWorker) Validate() error

Validate checks the field values on ApiWorker with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiWorker) ValidateAll

func (m *ApiWorker) ValidateAll() error

ValidateAll checks the field values on ApiWorker with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiWorkerMultiError, or nil if none found.

type ApiWorkerMultiError

type ApiWorkerMultiError []error

ApiWorkerMultiError is an error wrapping multiple validation errors returned by ApiWorker.ValidateAll() if the designated constraints aren't met.

func (ApiWorkerMultiError) AllErrors

func (m ApiWorkerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiWorkerMultiError) Error

func (m ApiWorkerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApiWorkerOptions added in v0.17.0

type ApiWorkerOptions struct {

	// Apply security definitions to this operation
	Security map[string]*ApiWorkerScopes `` /* 157-byte string literal not displayed */
	// explicitly disable security for this endpoint
	// We need to do this as the default value of a repeated field
	// is always empty so there is no way of knowing if security is explicitly disabled
	SecurityDisabled bool `protobuf:"varint,2,opt,name=security_disabled,json=securityDisabled,proto3" json:"security_disabled,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiWorkerOptions) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiWorkerOptions.ProtoReflect.Descriptor instead.

func (*ApiWorkerOptions) GetSecurity added in v0.17.0

func (x *ApiWorkerOptions) GetSecurity() map[string]*ApiWorkerScopes

func (*ApiWorkerOptions) GetSecurityDisabled added in v0.17.0

func (x *ApiWorkerOptions) GetSecurityDisabled() bool

func (*ApiWorkerOptions) ProtoMessage added in v0.17.0

func (*ApiWorkerOptions) ProtoMessage()

func (*ApiWorkerOptions) ProtoReflect added in v0.17.0

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

func (*ApiWorkerOptions) Reset added in v0.17.0

func (x *ApiWorkerOptions) Reset()

func (*ApiWorkerOptions) String added in v0.17.0

func (x *ApiWorkerOptions) String() string

func (*ApiWorkerOptions) Validate added in v0.17.0

func (m *ApiWorkerOptions) Validate() error

Validate checks the field values on ApiWorkerOptions with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiWorkerOptions) ValidateAll added in v0.17.0

func (m *ApiWorkerOptions) ValidateAll() error

ValidateAll checks the field values on ApiWorkerOptions with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiWorkerOptionsMultiError, or nil if none found.

type ApiWorkerOptionsMultiError added in v0.17.0

type ApiWorkerOptionsMultiError []error

ApiWorkerOptionsMultiError is an error wrapping multiple validation errors returned by ApiWorkerOptions.ValidateAll() if the designated constraints aren't met.

func (ApiWorkerOptionsMultiError) AllErrors added in v0.17.0

func (m ApiWorkerOptionsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiWorkerOptionsMultiError) Error added in v0.17.0

Error returns a concatenation of all the error messages it wraps.

type ApiWorkerOptionsValidationError added in v0.17.0

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

ApiWorkerOptionsValidationError is the validation error returned by ApiWorkerOptions.Validate if the designated constraints aren't met.

func (ApiWorkerOptionsValidationError) Cause added in v0.17.0

Cause function returns cause value.

func (ApiWorkerOptionsValidationError) Error added in v0.17.0

Error satisfies the builtin error interface

func (ApiWorkerOptionsValidationError) ErrorName added in v0.17.0

ErrorName returns error name.

func (ApiWorkerOptionsValidationError) Field added in v0.17.0

Field function returns field value.

func (ApiWorkerOptionsValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiWorkerOptionsValidationError) Reason added in v0.17.0

Reason function returns reason value.

type ApiWorkerScopes added in v0.17.0

type ApiWorkerScopes struct {
	Scopes []string `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiWorkerScopes) Descriptor deprecated added in v0.17.0

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

Deprecated: Use ApiWorkerScopes.ProtoReflect.Descriptor instead.

func (*ApiWorkerScopes) GetScopes added in v0.17.0

func (x *ApiWorkerScopes) GetScopes() []string

func (*ApiWorkerScopes) ProtoMessage added in v0.17.0

func (*ApiWorkerScopes) ProtoMessage()

func (*ApiWorkerScopes) ProtoReflect added in v0.17.0

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

func (*ApiWorkerScopes) Reset added in v0.17.0

func (x *ApiWorkerScopes) Reset()

func (*ApiWorkerScopes) String added in v0.17.0

func (x *ApiWorkerScopes) String() string

func (*ApiWorkerScopes) Validate added in v0.17.0

func (m *ApiWorkerScopes) Validate() error

Validate checks the field values on ApiWorkerScopes with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApiWorkerScopes) ValidateAll added in v0.17.0

func (m *ApiWorkerScopes) ValidateAll() error

ValidateAll checks the field values on ApiWorkerScopes with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApiWorkerScopesMultiError, or nil if none found.

type ApiWorkerScopesMultiError added in v0.17.0

type ApiWorkerScopesMultiError []error

ApiWorkerScopesMultiError is an error wrapping multiple validation errors returned by ApiWorkerScopes.ValidateAll() if the designated constraints aren't met.

func (ApiWorkerScopesMultiError) AllErrors added in v0.17.0

func (m ApiWorkerScopesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApiWorkerScopesMultiError) Error added in v0.17.0

Error returns a concatenation of all the error messages it wraps.

type ApiWorkerScopesValidationError added in v0.17.0

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

ApiWorkerScopesValidationError is the validation error returned by ApiWorkerScopes.Validate if the designated constraints aren't met.

func (ApiWorkerScopesValidationError) Cause added in v0.17.0

Cause function returns cause value.

func (ApiWorkerScopesValidationError) Error added in v0.17.0

Error satisfies the builtin error interface

func (ApiWorkerScopesValidationError) ErrorName added in v0.17.0

func (e ApiWorkerScopesValidationError) ErrorName() string

ErrorName returns error name.

func (ApiWorkerScopesValidationError) Field added in v0.17.0

Field function returns field value.

func (ApiWorkerScopesValidationError) Key added in v0.17.0

Key function returns key value.

func (ApiWorkerScopesValidationError) Reason added in v0.17.0

Reason function returns reason value.

type ApiWorkerValidationError

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

ApiWorkerValidationError is the validation error returned by ApiWorker.Validate if the designated constraints aren't met.

func (ApiWorkerValidationError) Cause

func (e ApiWorkerValidationError) Cause() error

Cause function returns cause value.

func (ApiWorkerValidationError) Error

func (e ApiWorkerValidationError) Error() string

Error satisfies the builtin error interface

func (ApiWorkerValidationError) ErrorName

func (e ApiWorkerValidationError) ErrorName() string

ErrorName returns error name.

func (ApiWorkerValidationError) Field

func (e ApiWorkerValidationError) Field() string

Field function returns field value.

func (ApiWorkerValidationError) Key

Key function returns key value.

func (ApiWorkerValidationError) Reason

func (e ApiWorkerValidationError) Reason() string

Reason function returns reason value.

type BucketResource

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

func (*BucketResource) Descriptor deprecated

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

Deprecated: Use BucketResource.ProtoReflect.Descriptor instead.

func (*BucketResource) ProtoMessage

func (*BucketResource) ProtoMessage()

func (*BucketResource) ProtoReflect

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

func (*BucketResource) Reset

func (x *BucketResource) Reset()

func (*BucketResource) String

func (x *BucketResource) String() string

func (*BucketResource) Validate

func (m *BucketResource) Validate() error

Validate checks the field values on BucketResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*BucketResource) ValidateAll

func (m *BucketResource) ValidateAll() error

ValidateAll checks the field values on BucketResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BucketResourceMultiError, or nil if none found.

type BucketResourceMultiError

type BucketResourceMultiError []error

BucketResourceMultiError is an error wrapping multiple validation errors returned by BucketResource.ValidateAll() if the designated constraints aren't met.

func (BucketResourceMultiError) AllErrors

func (m BucketResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BucketResourceMultiError) Error

func (m BucketResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BucketResourceValidationError

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

BucketResourceValidationError is the validation error returned by BucketResource.Validate if the designated constraints aren't met.

func (BucketResourceValidationError) Cause

Cause function returns cause value.

func (BucketResourceValidationError) Error

Error satisfies the builtin error interface

func (BucketResourceValidationError) ErrorName

func (e BucketResourceValidationError) ErrorName() string

ErrorName returns error name.

func (BucketResourceValidationError) Field

Field function returns field value.

func (BucketResourceValidationError) Key

Key function returns key value.

func (BucketResourceValidationError) Reason

Reason function returns reason value.

type ClientMessage

type ClientMessage struct {

	// Client message ID, used to pair requests/responses
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ClientMessage_InitRequest
	//	*ClientMessage_TriggerResponse
	Content isClientMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

Messages the client is able to send to the server

func (*ClientMessage) Descriptor deprecated

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

Deprecated: Use ClientMessage.ProtoReflect.Descriptor instead.

func (*ClientMessage) GetContent

func (m *ClientMessage) GetContent() isClientMessage_Content

func (*ClientMessage) GetId

func (x *ClientMessage) GetId() string

func (*ClientMessage) GetInitRequest

func (x *ClientMessage) GetInitRequest() *InitRequest

func (*ClientMessage) GetTriggerResponse

func (x *ClientMessage) GetTriggerResponse() *TriggerResponse

func (*ClientMessage) ProtoMessage

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) ProtoReflect

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

func (*ClientMessage) Reset

func (x *ClientMessage) Reset()

func (*ClientMessage) String

func (x *ClientMessage) String() string

func (*ClientMessage) Validate

func (m *ClientMessage) Validate() error

Validate checks the field values on ClientMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ClientMessage) ValidateAll

func (m *ClientMessage) ValidateAll() error

ValidateAll checks the field values on ClientMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientMessageMultiError, or nil if none found.

type ClientMessageMultiError

type ClientMessageMultiError []error

ClientMessageMultiError is an error wrapping multiple validation errors returned by ClientMessage.ValidateAll() if the designated constraints aren't met.

func (ClientMessageMultiError) AllErrors

func (m ClientMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClientMessageMultiError) Error

func (m ClientMessageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClientMessageValidationError

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

ClientMessageValidationError is the validation error returned by ClientMessage.Validate if the designated constraints aren't met.

func (ClientMessageValidationError) Cause

Cause function returns cause value.

func (ClientMessageValidationError) Error

Error satisfies the builtin error interface

func (ClientMessageValidationError) ErrorName

func (e ClientMessageValidationError) ErrorName() string

ErrorName returns error name.

func (ClientMessageValidationError) Field

Field function returns field value.

func (ClientMessageValidationError) Key

Key function returns key value.

func (ClientMessageValidationError) Reason

Reason function returns reason value.

type ClientMessage_InitRequest

type ClientMessage_InitRequest struct {
	// Client initialisation request
	// A worker will not be eligible for triggers
	// until it has identified itself
	InitRequest *InitRequest `protobuf:"bytes,2,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type ClientMessage_TriggerResponse

type ClientMessage_TriggerResponse struct {
	// Client responsding with result of
	// a trigger
	TriggerResponse *TriggerResponse `protobuf:"bytes,3,opt,name=trigger_response,json=triggerResponse,proto3,oneof"`
}

type Collection

type Collection struct {

	// The collection name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional parent key, required when the collection is a sub-collection of another document
	Parent *Key `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

Provides a Collection type for storing documents

func (*Collection) Descriptor deprecated

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

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetName

func (x *Collection) GetName() string

func (*Collection) GetParent

func (x *Collection) GetParent() *Key

func (*Collection) ProtoMessage

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect

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

func (*Collection) Reset

func (x *Collection) Reset()

func (*Collection) String

func (x *Collection) String() string

func (*Collection) Validate

func (m *Collection) Validate() error

Validate checks the field values on Collection with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Collection) ValidateAll

func (m *Collection) ValidateAll() error

ValidateAll checks the field values on Collection with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CollectionMultiError, or nil if none found.

type CollectionMultiError

type CollectionMultiError []error

CollectionMultiError is an error wrapping multiple validation errors returned by Collection.ValidateAll() if the designated constraints aren't met.

func (CollectionMultiError) AllErrors

func (m CollectionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CollectionMultiError) Error

func (m CollectionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CollectionResource

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

func (*CollectionResource) Descriptor deprecated

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

Deprecated: Use CollectionResource.ProtoReflect.Descriptor instead.

func (*CollectionResource) ProtoMessage

func (*CollectionResource) ProtoMessage()

func (*CollectionResource) ProtoReflect

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

func (*CollectionResource) Reset

func (x *CollectionResource) Reset()

func (*CollectionResource) String

func (x *CollectionResource) String() string

func (*CollectionResource) Validate

func (m *CollectionResource) Validate() error

Validate checks the field values on CollectionResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CollectionResource) ValidateAll

func (m *CollectionResource) ValidateAll() error

ValidateAll checks the field values on CollectionResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CollectionResourceMultiError, or nil if none found.

type CollectionResourceMultiError

type CollectionResourceMultiError []error

CollectionResourceMultiError is an error wrapping multiple validation errors returned by CollectionResource.ValidateAll() if the designated constraints aren't met.

func (CollectionResourceMultiError) AllErrors

func (m CollectionResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CollectionResourceMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CollectionResourceValidationError

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

CollectionResourceValidationError is the validation error returned by CollectionResource.Validate if the designated constraints aren't met.

func (CollectionResourceValidationError) Cause

Cause function returns cause value.

func (CollectionResourceValidationError) Error

Error satisfies the builtin error interface

func (CollectionResourceValidationError) ErrorName

ErrorName returns error name.

func (CollectionResourceValidationError) Field

Field function returns field value.

func (CollectionResourceValidationError) Key

Key function returns key value.

func (CollectionResourceValidationError) Reason

Reason function returns reason value.

type CollectionValidationError

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

CollectionValidationError is the validation error returned by Collection.Validate if the designated constraints aren't met.

func (CollectionValidationError) Cause

func (e CollectionValidationError) Cause() error

Cause function returns cause value.

func (CollectionValidationError) Error

Error satisfies the builtin error interface

func (CollectionValidationError) ErrorName

func (e CollectionValidationError) ErrorName() string

ErrorName returns error name.

func (CollectionValidationError) Field

Field function returns field value.

func (CollectionValidationError) Key

Key function returns key value.

func (CollectionValidationError) Reason

func (e CollectionValidationError) Reason() string

Reason function returns reason value.

type Document

type Document struct {

	// The document content (JSON object)
	Content *structpb.Struct `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// The document's unique key, including collection/sub-collections
	Key *Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Provides a return document type

func (*Document) Descriptor deprecated

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

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) GetContent

func (x *Document) GetContent() *structpb.Struct

func (*Document) GetKey

func (x *Document) GetKey() *Key

func (*Document) ProtoMessage

func (*Document) ProtoMessage()

func (*Document) ProtoReflect

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

func (*Document) Reset

func (x *Document) Reset()

func (*Document) String

func (x *Document) String() string

func (*Document) Validate

func (m *Document) Validate() error

Validate checks the field values on Document with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Document) ValidateAll

func (m *Document) ValidateAll() error

ValidateAll checks the field values on Document with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentMultiError, or nil if none found.

type DocumentDeleteRequest

type DocumentDeleteRequest struct {

	// Key of the document to delete
	Key *Key `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentDeleteRequest) Descriptor deprecated

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

Deprecated: Use DocumentDeleteRequest.ProtoReflect.Descriptor instead.

func (*DocumentDeleteRequest) GetKey

func (x *DocumentDeleteRequest) GetKey() *Key

func (*DocumentDeleteRequest) ProtoMessage

func (*DocumentDeleteRequest) ProtoMessage()

func (*DocumentDeleteRequest) ProtoReflect

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

func (*DocumentDeleteRequest) Reset

func (x *DocumentDeleteRequest) Reset()

func (*DocumentDeleteRequest) String

func (x *DocumentDeleteRequest) String() string

func (*DocumentDeleteRequest) Validate

func (m *DocumentDeleteRequest) Validate() error

Validate checks the field values on DocumentDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentDeleteRequest) ValidateAll

func (m *DocumentDeleteRequest) ValidateAll() error

ValidateAll checks the field values on DocumentDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentDeleteRequestMultiError, or nil if none found.

type DocumentDeleteRequestMultiError

type DocumentDeleteRequestMultiError []error

DocumentDeleteRequestMultiError is an error wrapping multiple validation errors returned by DocumentDeleteRequest.ValidateAll() if the designated constraints aren't met.

func (DocumentDeleteRequestMultiError) AllErrors

func (m DocumentDeleteRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentDeleteRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentDeleteRequestValidationError

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

DocumentDeleteRequestValidationError is the validation error returned by DocumentDeleteRequest.Validate if the designated constraints aren't met.

func (DocumentDeleteRequestValidationError) Cause

Cause function returns cause value.

func (DocumentDeleteRequestValidationError) Error

Error satisfies the builtin error interface

func (DocumentDeleteRequestValidationError) ErrorName

ErrorName returns error name.

func (DocumentDeleteRequestValidationError) Field

Field function returns field value.

func (DocumentDeleteRequestValidationError) Key

Key function returns key value.

func (DocumentDeleteRequestValidationError) Reason

Reason function returns reason value.

type DocumentDeleteResponse

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

func (*DocumentDeleteResponse) Descriptor deprecated

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

Deprecated: Use DocumentDeleteResponse.ProtoReflect.Descriptor instead.

func (*DocumentDeleteResponse) ProtoMessage

func (*DocumentDeleteResponse) ProtoMessage()

func (*DocumentDeleteResponse) ProtoReflect

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

func (*DocumentDeleteResponse) Reset

func (x *DocumentDeleteResponse) Reset()

func (*DocumentDeleteResponse) String

func (x *DocumentDeleteResponse) String() string

func (*DocumentDeleteResponse) Validate

func (m *DocumentDeleteResponse) Validate() error

Validate checks the field values on DocumentDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentDeleteResponse) ValidateAll

func (m *DocumentDeleteResponse) ValidateAll() error

ValidateAll checks the field values on DocumentDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentDeleteResponseMultiError, or nil if none found.

type DocumentDeleteResponseMultiError

type DocumentDeleteResponseMultiError []error

DocumentDeleteResponseMultiError is an error wrapping multiple validation errors returned by DocumentDeleteResponse.ValidateAll() if the designated constraints aren't met.

func (DocumentDeleteResponseMultiError) AllErrors

func (m DocumentDeleteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentDeleteResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentDeleteResponseValidationError

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

DocumentDeleteResponseValidationError is the validation error returned by DocumentDeleteResponse.Validate if the designated constraints aren't met.

func (DocumentDeleteResponseValidationError) Cause

Cause function returns cause value.

func (DocumentDeleteResponseValidationError) Error

Error satisfies the builtin error interface

func (DocumentDeleteResponseValidationError) ErrorName

ErrorName returns error name.

func (DocumentDeleteResponseValidationError) Field

Field function returns field value.

func (DocumentDeleteResponseValidationError) Key

Key function returns key value.

func (DocumentDeleteResponseValidationError) Reason

Reason function returns reason value.

type DocumentGetRequest

type DocumentGetRequest struct {

	// Key of the document to retrieve
	Key *Key `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentGetRequest) Descriptor deprecated

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

Deprecated: Use DocumentGetRequest.ProtoReflect.Descriptor instead.

func (*DocumentGetRequest) GetKey

func (x *DocumentGetRequest) GetKey() *Key

func (*DocumentGetRequest) ProtoMessage

func (*DocumentGetRequest) ProtoMessage()

func (*DocumentGetRequest) ProtoReflect

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

func (*DocumentGetRequest) Reset

func (x *DocumentGetRequest) Reset()

func (*DocumentGetRequest) String

func (x *DocumentGetRequest) String() string

func (*DocumentGetRequest) Validate

func (m *DocumentGetRequest) Validate() error

Validate checks the field values on DocumentGetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentGetRequest) ValidateAll

func (m *DocumentGetRequest) ValidateAll() error

ValidateAll checks the field values on DocumentGetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentGetRequestMultiError, or nil if none found.

type DocumentGetRequestMultiError

type DocumentGetRequestMultiError []error

DocumentGetRequestMultiError is an error wrapping multiple validation errors returned by DocumentGetRequest.ValidateAll() if the designated constraints aren't met.

func (DocumentGetRequestMultiError) AllErrors

func (m DocumentGetRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentGetRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentGetRequestValidationError

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

DocumentGetRequestValidationError is the validation error returned by DocumentGetRequest.Validate if the designated constraints aren't met.

func (DocumentGetRequestValidationError) Cause

Cause function returns cause value.

func (DocumentGetRequestValidationError) Error

Error satisfies the builtin error interface

func (DocumentGetRequestValidationError) ErrorName

ErrorName returns error name.

func (DocumentGetRequestValidationError) Field

Field function returns field value.

func (DocumentGetRequestValidationError) Key

Key function returns key value.

func (DocumentGetRequestValidationError) Reason

Reason function returns reason value.

type DocumentGetResponse

type DocumentGetResponse struct {

	// The retrieved value
	Document *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentGetResponse) Descriptor deprecated

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

Deprecated: Use DocumentGetResponse.ProtoReflect.Descriptor instead.

func (*DocumentGetResponse) GetDocument

func (x *DocumentGetResponse) GetDocument() *Document

func (*DocumentGetResponse) ProtoMessage

func (*DocumentGetResponse) ProtoMessage()

func (*DocumentGetResponse) ProtoReflect

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

func (*DocumentGetResponse) Reset

func (x *DocumentGetResponse) Reset()

func (*DocumentGetResponse) String

func (x *DocumentGetResponse) String() string

func (*DocumentGetResponse) Validate

func (m *DocumentGetResponse) Validate() error

Validate checks the field values on DocumentGetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentGetResponse) ValidateAll

func (m *DocumentGetResponse) ValidateAll() error

ValidateAll checks the field values on DocumentGetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentGetResponseMultiError, or nil if none found.

type DocumentGetResponseMultiError

type DocumentGetResponseMultiError []error

DocumentGetResponseMultiError is an error wrapping multiple validation errors returned by DocumentGetResponse.ValidateAll() if the designated constraints aren't met.

func (DocumentGetResponseMultiError) AllErrors

func (m DocumentGetResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentGetResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentGetResponseValidationError

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

DocumentGetResponseValidationError is the validation error returned by DocumentGetResponse.Validate if the designated constraints aren't met.

func (DocumentGetResponseValidationError) Cause

Cause function returns cause value.

func (DocumentGetResponseValidationError) Error

Error satisfies the builtin error interface

func (DocumentGetResponseValidationError) ErrorName

ErrorName returns error name.

func (DocumentGetResponseValidationError) Field

Field function returns field value.

func (DocumentGetResponseValidationError) Key

Key function returns key value.

func (DocumentGetResponseValidationError) Reason

Reason function returns reason value.

type DocumentMultiError

type DocumentMultiError []error

DocumentMultiError is an error wrapping multiple validation errors returned by Document.ValidateAll() if the designated constraints aren't met.

func (DocumentMultiError) AllErrors

func (m DocumentMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentMultiError) Error

func (m DocumentMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DocumentQueryRequest

type DocumentQueryRequest struct {

	// The collection to query
	Collection *Collection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// Optional query expressions
	Expressions []*Expression `protobuf:"bytes,3,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// Optional query fetch limit
	Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Optional query paging continuation token
	PagingToken map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DocumentQueryRequest) Descriptor deprecated

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

Deprecated: Use DocumentQueryRequest.ProtoReflect.Descriptor instead.

func (*DocumentQueryRequest) GetCollection

func (x *DocumentQueryRequest) GetCollection() *Collection

func (*DocumentQueryRequest) GetExpressions

func (x *DocumentQueryRequest) GetExpressions() []*Expression

func (*DocumentQueryRequest) GetLimit

func (x *DocumentQueryRequest) GetLimit() int32

func (*DocumentQueryRequest) GetPagingToken

func (x *DocumentQueryRequest) GetPagingToken() map[string]string

func (*DocumentQueryRequest) ProtoMessage

func (*DocumentQueryRequest) ProtoMessage()

func (*DocumentQueryRequest) ProtoReflect

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

func (*DocumentQueryRequest) Reset

func (x *DocumentQueryRequest) Reset()

func (*DocumentQueryRequest) String

func (x *DocumentQueryRequest) String() string

func (*DocumentQueryRequest) Validate

func (m *DocumentQueryRequest) Validate() error

Validate checks the field values on DocumentQueryRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentQueryRequest) ValidateAll

func (m *DocumentQueryRequest) ValidateAll() error

ValidateAll checks the field values on DocumentQueryRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentQueryRequestMultiError, or nil if none found.

type DocumentQueryRequestMultiError

type DocumentQueryRequestMultiError []error

DocumentQueryRequestMultiError is an error wrapping multiple validation errors returned by DocumentQueryRequest.ValidateAll() if the designated constraints aren't met.

func (DocumentQueryRequestMultiError) AllErrors

func (m DocumentQueryRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentQueryRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentQueryRequestValidationError

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

DocumentQueryRequestValidationError is the validation error returned by DocumentQueryRequest.Validate if the designated constraints aren't met.

func (DocumentQueryRequestValidationError) Cause

Cause function returns cause value.

func (DocumentQueryRequestValidationError) Error

Error satisfies the builtin error interface

func (DocumentQueryRequestValidationError) ErrorName

ErrorName returns error name.

func (DocumentQueryRequestValidationError) Field

Field function returns field value.

func (DocumentQueryRequestValidationError) Key

Key function returns key value.

func (DocumentQueryRequestValidationError) Reason

Reason function returns reason value.

type DocumentQueryResponse

type DocumentQueryResponse struct {

	// The retrieved values
	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	// The query paging continuation token, when empty no further results are available
	PagingToken map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DocumentQueryResponse) Descriptor deprecated

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

Deprecated: Use DocumentQueryResponse.ProtoReflect.Descriptor instead.

func (*DocumentQueryResponse) GetDocuments

func (x *DocumentQueryResponse) GetDocuments() []*Document

func (*DocumentQueryResponse) GetPagingToken

func (x *DocumentQueryResponse) GetPagingToken() map[string]string

func (*DocumentQueryResponse) ProtoMessage

func (*DocumentQueryResponse) ProtoMessage()

func (*DocumentQueryResponse) ProtoReflect

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

func (*DocumentQueryResponse) Reset

func (x *DocumentQueryResponse) Reset()

func (*DocumentQueryResponse) String

func (x *DocumentQueryResponse) String() string

func (*DocumentQueryResponse) Validate

func (m *DocumentQueryResponse) Validate() error

Validate checks the field values on DocumentQueryResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentQueryResponse) ValidateAll

func (m *DocumentQueryResponse) ValidateAll() error

ValidateAll checks the field values on DocumentQueryResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentQueryResponseMultiError, or nil if none found.

type DocumentQueryResponseMultiError

type DocumentQueryResponseMultiError []error

DocumentQueryResponseMultiError is an error wrapping multiple validation errors returned by DocumentQueryResponse.ValidateAll() if the designated constraints aren't met.

func (DocumentQueryResponseMultiError) AllErrors

func (m DocumentQueryResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentQueryResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentQueryResponseValidationError

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

DocumentQueryResponseValidationError is the validation error returned by DocumentQueryResponse.Validate if the designated constraints aren't met.

func (DocumentQueryResponseValidationError) Cause

Cause function returns cause value.

func (DocumentQueryResponseValidationError) Error

Error satisfies the builtin error interface

func (DocumentQueryResponseValidationError) ErrorName

ErrorName returns error name.

func (DocumentQueryResponseValidationError) Field

Field function returns field value.

func (DocumentQueryResponseValidationError) Key

Key function returns key value.

func (DocumentQueryResponseValidationError) Reason

Reason function returns reason value.

type DocumentQueryStreamRequest

type DocumentQueryStreamRequest struct {

	// The collection to query
	Collection *Collection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// Optional query expressions
	Expressions []*Expression `protobuf:"bytes,3,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// Optional query fetch limit
	Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentQueryStreamRequest) Descriptor deprecated

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

Deprecated: Use DocumentQueryStreamRequest.ProtoReflect.Descriptor instead.

func (*DocumentQueryStreamRequest) GetCollection

func (x *DocumentQueryStreamRequest) GetCollection() *Collection

func (*DocumentQueryStreamRequest) GetExpressions

func (x *DocumentQueryStreamRequest) GetExpressions() []*Expression

func (*DocumentQueryStreamRequest) GetLimit

func (x *DocumentQueryStreamRequest) GetLimit() int32

func (*DocumentQueryStreamRequest) ProtoMessage

func (*DocumentQueryStreamRequest) ProtoMessage()

func (*DocumentQueryStreamRequest) ProtoReflect

func (*DocumentQueryStreamRequest) Reset

func (x *DocumentQueryStreamRequest) Reset()

func (*DocumentQueryStreamRequest) String

func (x *DocumentQueryStreamRequest) String() string

func (*DocumentQueryStreamRequest) Validate

func (m *DocumentQueryStreamRequest) Validate() error

Validate checks the field values on DocumentQueryStreamRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentQueryStreamRequest) ValidateAll

func (m *DocumentQueryStreamRequest) ValidateAll() error

ValidateAll checks the field values on DocumentQueryStreamRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentQueryStreamRequestMultiError, or nil if none found.

type DocumentQueryStreamRequestMultiError

type DocumentQueryStreamRequestMultiError []error

DocumentQueryStreamRequestMultiError is an error wrapping multiple validation errors returned by DocumentQueryStreamRequest.ValidateAll() if the designated constraints aren't met.

func (DocumentQueryStreamRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (DocumentQueryStreamRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentQueryStreamRequestValidationError

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

DocumentQueryStreamRequestValidationError is the validation error returned by DocumentQueryStreamRequest.Validate if the designated constraints aren't met.

func (DocumentQueryStreamRequestValidationError) Cause

Cause function returns cause value.

func (DocumentQueryStreamRequestValidationError) Error

Error satisfies the builtin error interface

func (DocumentQueryStreamRequestValidationError) ErrorName

ErrorName returns error name.

func (DocumentQueryStreamRequestValidationError) Field

Field function returns field value.

func (DocumentQueryStreamRequestValidationError) Key

Key function returns key value.

func (DocumentQueryStreamRequestValidationError) Reason

Reason function returns reason value.

type DocumentQueryStreamResponse

type DocumentQueryStreamResponse struct {

	// The stream document
	Document *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentQueryStreamResponse) Descriptor deprecated

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

Deprecated: Use DocumentQueryStreamResponse.ProtoReflect.Descriptor instead.

func (*DocumentQueryStreamResponse) GetDocument

func (x *DocumentQueryStreamResponse) GetDocument() *Document

func (*DocumentQueryStreamResponse) ProtoMessage

func (*DocumentQueryStreamResponse) ProtoMessage()

func (*DocumentQueryStreamResponse) ProtoReflect

func (*DocumentQueryStreamResponse) Reset

func (x *DocumentQueryStreamResponse) Reset()

func (*DocumentQueryStreamResponse) String

func (x *DocumentQueryStreamResponse) String() string

func (*DocumentQueryStreamResponse) Validate

func (m *DocumentQueryStreamResponse) Validate() error

Validate checks the field values on DocumentQueryStreamResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentQueryStreamResponse) ValidateAll

func (m *DocumentQueryStreamResponse) ValidateAll() error

ValidateAll checks the field values on DocumentQueryStreamResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentQueryStreamResponseMultiError, or nil if none found.

type DocumentQueryStreamResponseMultiError

type DocumentQueryStreamResponseMultiError []error

DocumentQueryStreamResponseMultiError is an error wrapping multiple validation errors returned by DocumentQueryStreamResponse.ValidateAll() if the designated constraints aren't met.

func (DocumentQueryStreamResponseMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (DocumentQueryStreamResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentQueryStreamResponseValidationError

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

DocumentQueryStreamResponseValidationError is the validation error returned by DocumentQueryStreamResponse.Validate if the designated constraints aren't met.

func (DocumentQueryStreamResponseValidationError) Cause

Cause function returns cause value.

func (DocumentQueryStreamResponseValidationError) Error

Error satisfies the builtin error interface

func (DocumentQueryStreamResponseValidationError) ErrorName

ErrorName returns error name.

func (DocumentQueryStreamResponseValidationError) Field

Field function returns field value.

func (DocumentQueryStreamResponseValidationError) Key

Key function returns key value.

func (DocumentQueryStreamResponseValidationError) Reason

Reason function returns reason value.

type DocumentServiceClient

type DocumentServiceClient interface {
	// Get an existing document
	Get(ctx context.Context, in *DocumentGetRequest, opts ...grpc.CallOption) (*DocumentGetResponse, error)
	// Create a new or overwrite an existing document
	Set(ctx context.Context, in *DocumentSetRequest, opts ...grpc.CallOption) (*DocumentSetResponse, error)
	// Delete an existing document
	Delete(ctx context.Context, in *DocumentDeleteRequest, opts ...grpc.CallOption) (*DocumentDeleteResponse, error)
	// Query the document collection (supports pagination)
	Query(ctx context.Context, in *DocumentQueryRequest, opts ...grpc.CallOption) (*DocumentQueryResponse, error)
	// Query the document collection (supports streaming)
	QueryStream(ctx context.Context, in *DocumentQueryStreamRequest, opts ...grpc.CallOption) (DocumentService_QueryStreamClient, error)
}

DocumentServiceClient is the client API for DocumentService 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.

type DocumentServiceServer

type DocumentServiceServer interface {
	// Get an existing document
	Get(context.Context, *DocumentGetRequest) (*DocumentGetResponse, error)
	// Create a new or overwrite an existing document
	Set(context.Context, *DocumentSetRequest) (*DocumentSetResponse, error)
	// Delete an existing document
	Delete(context.Context, *DocumentDeleteRequest) (*DocumentDeleteResponse, error)
	// Query the document collection (supports pagination)
	Query(context.Context, *DocumentQueryRequest) (*DocumentQueryResponse, error)
	// Query the document collection (supports streaming)
	QueryStream(*DocumentQueryStreamRequest, DocumentService_QueryStreamServer) error
	// contains filtered or unexported methods
}

DocumentServiceServer is the server API for DocumentService service. All implementations must embed UnimplementedDocumentServiceServer for forward compatibility

type DocumentService_QueryStreamClient

type DocumentService_QueryStreamClient interface {
	Recv() (*DocumentQueryStreamResponse, error)
	grpc.ClientStream
}

type DocumentService_QueryStreamServer

type DocumentService_QueryStreamServer interface {
	Send(*DocumentQueryStreamResponse) error
	grpc.ServerStream
}

type DocumentSetRequest

type DocumentSetRequest struct {

	// Key of the document to set
	Key *Key `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The document content to store (JSON object)
	Content *structpb.Struct `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentSetRequest) Descriptor deprecated

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

Deprecated: Use DocumentSetRequest.ProtoReflect.Descriptor instead.

func (*DocumentSetRequest) GetContent

func (x *DocumentSetRequest) GetContent() *structpb.Struct

func (*DocumentSetRequest) GetKey

func (x *DocumentSetRequest) GetKey() *Key

func (*DocumentSetRequest) ProtoMessage

func (*DocumentSetRequest) ProtoMessage()

func (*DocumentSetRequest) ProtoReflect

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

func (*DocumentSetRequest) Reset

func (x *DocumentSetRequest) Reset()

func (*DocumentSetRequest) String

func (x *DocumentSetRequest) String() string

func (*DocumentSetRequest) Validate

func (m *DocumentSetRequest) Validate() error

Validate checks the field values on DocumentSetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentSetRequest) ValidateAll

func (m *DocumentSetRequest) ValidateAll() error

ValidateAll checks the field values on DocumentSetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentSetRequestMultiError, or nil if none found.

type DocumentSetRequestMultiError

type DocumentSetRequestMultiError []error

DocumentSetRequestMultiError is an error wrapping multiple validation errors returned by DocumentSetRequest.ValidateAll() if the designated constraints aren't met.

func (DocumentSetRequestMultiError) AllErrors

func (m DocumentSetRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentSetRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentSetRequestValidationError

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

DocumentSetRequestValidationError is the validation error returned by DocumentSetRequest.Validate if the designated constraints aren't met.

func (DocumentSetRequestValidationError) Cause

Cause function returns cause value.

func (DocumentSetRequestValidationError) Error

Error satisfies the builtin error interface

func (DocumentSetRequestValidationError) ErrorName

ErrorName returns error name.

func (DocumentSetRequestValidationError) Field

Field function returns field value.

func (DocumentSetRequestValidationError) Key

Key function returns key value.

func (DocumentSetRequestValidationError) Reason

Reason function returns reason value.

type DocumentSetResponse

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

func (*DocumentSetResponse) Descriptor deprecated

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

Deprecated: Use DocumentSetResponse.ProtoReflect.Descriptor instead.

func (*DocumentSetResponse) ProtoMessage

func (*DocumentSetResponse) ProtoMessage()

func (*DocumentSetResponse) ProtoReflect

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

func (*DocumentSetResponse) Reset

func (x *DocumentSetResponse) Reset()

func (*DocumentSetResponse) String

func (x *DocumentSetResponse) String() string

func (*DocumentSetResponse) Validate

func (m *DocumentSetResponse) Validate() error

Validate checks the field values on DocumentSetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentSetResponse) ValidateAll

func (m *DocumentSetResponse) ValidateAll() error

ValidateAll checks the field values on DocumentSetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentSetResponseMultiError, or nil if none found.

type DocumentSetResponseMultiError

type DocumentSetResponseMultiError []error

DocumentSetResponseMultiError is an error wrapping multiple validation errors returned by DocumentSetResponse.ValidateAll() if the designated constraints aren't met.

func (DocumentSetResponseMultiError) AllErrors

func (m DocumentSetResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentSetResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentSetResponseValidationError

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

DocumentSetResponseValidationError is the validation error returned by DocumentSetResponse.Validate if the designated constraints aren't met.

func (DocumentSetResponseValidationError) Cause

Cause function returns cause value.

func (DocumentSetResponseValidationError) Error

Error satisfies the builtin error interface

func (DocumentSetResponseValidationError) ErrorName

ErrorName returns error name.

func (DocumentSetResponseValidationError) Field

Field function returns field value.

func (DocumentSetResponseValidationError) Key

Key function returns key value.

func (DocumentSetResponseValidationError) Reason

Reason function returns reason value.

type DocumentValidationError

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

DocumentValidationError is the validation error returned by Document.Validate if the designated constraints aren't met.

func (DocumentValidationError) Cause

func (e DocumentValidationError) Cause() error

Cause function returns cause value.

func (DocumentValidationError) Error

func (e DocumentValidationError) Error() string

Error satisfies the builtin error interface

func (DocumentValidationError) ErrorName

func (e DocumentValidationError) ErrorName() string

ErrorName returns error name.

func (DocumentValidationError) Field

func (e DocumentValidationError) Field() string

Field function returns field value.

func (DocumentValidationError) Key

func (e DocumentValidationError) Key() bool

Key function returns key value.

func (DocumentValidationError) Reason

func (e DocumentValidationError) Reason() string

Reason function returns reason value.

type ErrorDetails

type ErrorDetails struct {

	// The developer error message, explaining the error and ideally solution.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The error root cause.
	Cause string `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	// The scope of the error.
	Scope *ErrorScope `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorDetails) Descriptor deprecated

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

Deprecated: Use ErrorDetails.ProtoReflect.Descriptor instead.

func (*ErrorDetails) GetCause

func (x *ErrorDetails) GetCause() string

func (*ErrorDetails) GetMessage

func (x *ErrorDetails) GetMessage() string

func (*ErrorDetails) GetScope

func (x *ErrorDetails) GetScope() *ErrorScope

func (*ErrorDetails) ProtoMessage

func (*ErrorDetails) ProtoMessage()

func (*ErrorDetails) ProtoReflect

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

func (*ErrorDetails) Reset

func (x *ErrorDetails) Reset()

func (*ErrorDetails) String

func (x *ErrorDetails) String() string

func (*ErrorDetails) Validate

func (m *ErrorDetails) Validate() error

Validate checks the field values on ErrorDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ErrorDetails) ValidateAll

func (m *ErrorDetails) ValidateAll() error

ValidateAll checks the field values on ErrorDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ErrorDetailsMultiError, or nil if none found.

type ErrorDetailsMultiError

type ErrorDetailsMultiError []error

ErrorDetailsMultiError is an error wrapping multiple validation errors returned by ErrorDetails.ValidateAll() if the designated constraints aren't met.

func (ErrorDetailsMultiError) AllErrors

func (m ErrorDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ErrorDetailsMultiError) Error

func (m ErrorDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ErrorDetailsValidationError

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

ErrorDetailsValidationError is the validation error returned by ErrorDetails.Validate if the designated constraints aren't met.

func (ErrorDetailsValidationError) Cause

Cause function returns cause value.

func (ErrorDetailsValidationError) Error

Error satisfies the builtin error interface

func (ErrorDetailsValidationError) ErrorName

func (e ErrorDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorDetailsValidationError) Field

Field function returns field value.

func (ErrorDetailsValidationError) Key

Key function returns key value.

func (ErrorDetailsValidationError) Reason

Reason function returns reason value.

type ErrorScope

type ErrorScope struct {

	// The API service invoked, e.g. 'Service.Method'.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// The plugin method invoked, e.g. 'PluginService.Method'.
	Plugin string `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// The plugin method arguments, ensure only non-sensitive data is specified.
	Args map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ErrorScope) Descriptor deprecated

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

Deprecated: Use ErrorScope.ProtoReflect.Descriptor instead.

func (*ErrorScope) GetArgs

func (x *ErrorScope) GetArgs() map[string]string

func (*ErrorScope) GetPlugin

func (x *ErrorScope) GetPlugin() string

func (*ErrorScope) GetService

func (x *ErrorScope) GetService() string

func (*ErrorScope) ProtoMessage

func (*ErrorScope) ProtoMessage()

func (*ErrorScope) ProtoReflect

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

func (*ErrorScope) Reset

func (x *ErrorScope) Reset()

func (*ErrorScope) String

func (x *ErrorScope) String() string

func (*ErrorScope) Validate

func (m *ErrorScope) Validate() error

Validate checks the field values on ErrorScope with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ErrorScope) ValidateAll

func (m *ErrorScope) ValidateAll() error

ValidateAll checks the field values on ErrorScope with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ErrorScopeMultiError, or nil if none found.

type ErrorScopeMultiError

type ErrorScopeMultiError []error

ErrorScopeMultiError is an error wrapping multiple validation errors returned by ErrorScope.ValidateAll() if the designated constraints aren't met.

func (ErrorScopeMultiError) AllErrors

func (m ErrorScopeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ErrorScopeMultiError) Error

func (m ErrorScopeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ErrorScopeValidationError

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

ErrorScopeValidationError is the validation error returned by ErrorScope.Validate if the designated constraints aren't met.

func (ErrorScopeValidationError) Cause

func (e ErrorScopeValidationError) Cause() error

Cause function returns cause value.

func (ErrorScopeValidationError) Error

Error satisfies the builtin error interface

func (ErrorScopeValidationError) ErrorName

func (e ErrorScopeValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorScopeValidationError) Field

Field function returns field value.

func (ErrorScopeValidationError) Key

Key function returns key value.

func (ErrorScopeValidationError) Reason

func (e ErrorScopeValidationError) Reason() string

Reason function returns reason value.

type EventPublishRequest

type EventPublishRequest struct {

	// The name of the topic to publish the event to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The event to be published
	Event *NitricEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// An optional delay specified in seconds (minimum 10 seconds)
	Delay uint32 `protobuf:"varint,3,opt,name=delay,proto3" json:"delay,omitempty"`
	// contains filtered or unexported fields
}

Request to publish an event to a topic

func (*EventPublishRequest) Descriptor deprecated

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

Deprecated: Use EventPublishRequest.ProtoReflect.Descriptor instead.

func (*EventPublishRequest) GetDelay added in v0.19.0

func (x *EventPublishRequest) GetDelay() uint32

func (*EventPublishRequest) GetEvent

func (x *EventPublishRequest) GetEvent() *NitricEvent

func (*EventPublishRequest) GetTopic

func (x *EventPublishRequest) GetTopic() string

func (*EventPublishRequest) ProtoMessage

func (*EventPublishRequest) ProtoMessage()

func (*EventPublishRequest) ProtoReflect

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

func (*EventPublishRequest) Reset

func (x *EventPublishRequest) Reset()

func (*EventPublishRequest) String

func (x *EventPublishRequest) String() string

func (*EventPublishRequest) Validate

func (m *EventPublishRequest) Validate() error

Validate checks the field values on EventPublishRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EventPublishRequest) ValidateAll

func (m *EventPublishRequest) ValidateAll() error

ValidateAll checks the field values on EventPublishRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventPublishRequestMultiError, or nil if none found.

type EventPublishRequestMultiError

type EventPublishRequestMultiError []error

EventPublishRequestMultiError is an error wrapping multiple validation errors returned by EventPublishRequest.ValidateAll() if the designated constraints aren't met.

func (EventPublishRequestMultiError) AllErrors

func (m EventPublishRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EventPublishRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type EventPublishRequestValidationError

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

EventPublishRequestValidationError is the validation error returned by EventPublishRequest.Validate if the designated constraints aren't met.

func (EventPublishRequestValidationError) Cause

Cause function returns cause value.

func (EventPublishRequestValidationError) Error

Error satisfies the builtin error interface

func (EventPublishRequestValidationError) ErrorName

ErrorName returns error name.

func (EventPublishRequestValidationError) Field

Field function returns field value.

func (EventPublishRequestValidationError) Key

Key function returns key value.

func (EventPublishRequestValidationError) Reason

Reason function returns reason value.

type EventPublishResponse

type EventPublishResponse struct {

	// The id of the published message
	// When an id was not supplied
	// one should be automatically generated
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Result of publishing an event

func (*EventPublishResponse) Descriptor deprecated

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

Deprecated: Use EventPublishResponse.ProtoReflect.Descriptor instead.

func (*EventPublishResponse) GetId

func (x *EventPublishResponse) GetId() string

func (*EventPublishResponse) ProtoMessage

func (*EventPublishResponse) ProtoMessage()

func (*EventPublishResponse) ProtoReflect

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

func (*EventPublishResponse) Reset

func (x *EventPublishResponse) Reset()

func (*EventPublishResponse) String

func (x *EventPublishResponse) String() string

func (*EventPublishResponse) Validate

func (m *EventPublishResponse) Validate() error

Validate checks the field values on EventPublishResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EventPublishResponse) ValidateAll

func (m *EventPublishResponse) ValidateAll() error

ValidateAll checks the field values on EventPublishResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventPublishResponseMultiError, or nil if none found.

type EventPublishResponseMultiError

type EventPublishResponseMultiError []error

EventPublishResponseMultiError is an error wrapping multiple validation errors returned by EventPublishResponse.ValidateAll() if the designated constraints aren't met.

func (EventPublishResponseMultiError) AllErrors

func (m EventPublishResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EventPublishResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type EventPublishResponseValidationError

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

EventPublishResponseValidationError is the validation error returned by EventPublishResponse.Validate if the designated constraints aren't met.

func (EventPublishResponseValidationError) Cause

Cause function returns cause value.

func (EventPublishResponseValidationError) Error

Error satisfies the builtin error interface

func (EventPublishResponseValidationError) ErrorName

ErrorName returns error name.

func (EventPublishResponseValidationError) Field

Field function returns field value.

func (EventPublishResponseValidationError) Key

Key function returns key value.

func (EventPublishResponseValidationError) Reason

Reason function returns reason value.

type EventServiceClient

type EventServiceClient interface {
	// Publishes an message to a given topic
	Publish(ctx context.Context, in *EventPublishRequest, opts ...grpc.CallOption) (*EventPublishResponse, error)
}

EventServiceClient is the client API for EventService 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.

type EventServiceServer

type EventServiceServer interface {
	// Publishes an message to a given topic
	Publish(context.Context, *EventPublishRequest) (*EventPublishResponse, error)
	// contains filtered or unexported methods
}

EventServiceServer is the server API for EventService service. All implementations must embed UnimplementedEventServiceServer for forward compatibility

type Expression

type Expression struct {

	// The query operand or attribute
	Operand string `protobuf:"bytes,1,opt,name=operand,proto3" json:"operand,omitempty"`
	// The query operator [ == | < | <= | > | >= | startsWith ]
	Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	// The query expression value
	Value *ExpressionValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Provides a query expression type

func (*Expression) Descriptor deprecated

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

Deprecated: Use Expression.ProtoReflect.Descriptor instead.

func (*Expression) GetOperand

func (x *Expression) GetOperand() string

func (*Expression) GetOperator

func (x *Expression) GetOperator() string

func (*Expression) GetValue

func (x *Expression) GetValue() *ExpressionValue

func (*Expression) ProtoMessage

func (*Expression) ProtoMessage()

func (*Expression) ProtoReflect

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

func (*Expression) Reset

func (x *Expression) Reset()

func (*Expression) String

func (x *Expression) String() string

func (*Expression) Validate

func (m *Expression) Validate() error

Validate checks the field values on Expression with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Expression) ValidateAll

func (m *Expression) ValidateAll() error

ValidateAll checks the field values on Expression with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExpressionMultiError, or nil if none found.

type ExpressionMultiError

type ExpressionMultiError []error

ExpressionMultiError is an error wrapping multiple validation errors returned by Expression.ValidateAll() if the designated constraints aren't met.

func (ExpressionMultiError) AllErrors

func (m ExpressionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExpressionMultiError) Error

func (m ExpressionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExpressionValidationError

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

ExpressionValidationError is the validation error returned by Expression.Validate if the designated constraints aren't met.

func (ExpressionValidationError) Cause

func (e ExpressionValidationError) Cause() error

Cause function returns cause value.

func (ExpressionValidationError) Error

Error satisfies the builtin error interface

func (ExpressionValidationError) ErrorName

func (e ExpressionValidationError) ErrorName() string

ErrorName returns error name.

func (ExpressionValidationError) Field

Field function returns field value.

func (ExpressionValidationError) Key

Key function returns key value.

func (ExpressionValidationError) Reason

func (e ExpressionValidationError) Reason() string

Reason function returns reason value.

type ExpressionValue

type ExpressionValue struct {

	// The kind of value.
	//
	// Types that are assignable to Kind:
	//
	//	*ExpressionValue_IntValue
	//	*ExpressionValue_DoubleValue
	//	*ExpressionValue_StringValue
	//	*ExpressionValue_BoolValue
	Kind isExpressionValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*ExpressionValue) Descriptor deprecated

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

Deprecated: Use ExpressionValue.ProtoReflect.Descriptor instead.

func (*ExpressionValue) GetBoolValue

func (x *ExpressionValue) GetBoolValue() bool

func (*ExpressionValue) GetDoubleValue

func (x *ExpressionValue) GetDoubleValue() float64

func (*ExpressionValue) GetIntValue

func (x *ExpressionValue) GetIntValue() int64

func (*ExpressionValue) GetKind

func (m *ExpressionValue) GetKind() isExpressionValue_Kind

func (*ExpressionValue) GetStringValue

func (x *ExpressionValue) GetStringValue() string

func (*ExpressionValue) ProtoMessage

func (*ExpressionValue) ProtoMessage()

func (*ExpressionValue) ProtoReflect

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

func (*ExpressionValue) Reset

func (x *ExpressionValue) Reset()

func (*ExpressionValue) String

func (x *ExpressionValue) String() string

func (*ExpressionValue) Validate

func (m *ExpressionValue) Validate() error

Validate checks the field values on ExpressionValue with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExpressionValue) ValidateAll

func (m *ExpressionValue) ValidateAll() error

ValidateAll checks the field values on ExpressionValue with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExpressionValueMultiError, or nil if none found.

type ExpressionValueMultiError

type ExpressionValueMultiError []error

ExpressionValueMultiError is an error wrapping multiple validation errors returned by ExpressionValue.ValidateAll() if the designated constraints aren't met.

func (ExpressionValueMultiError) AllErrors

func (m ExpressionValueMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExpressionValueMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ExpressionValueValidationError

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

ExpressionValueValidationError is the validation error returned by ExpressionValue.Validate if the designated constraints aren't met.

func (ExpressionValueValidationError) Cause

Cause function returns cause value.

func (ExpressionValueValidationError) Error

Error satisfies the builtin error interface

func (ExpressionValueValidationError) ErrorName

func (e ExpressionValueValidationError) ErrorName() string

ErrorName returns error name.

func (ExpressionValueValidationError) Field

Field function returns field value.

func (ExpressionValueValidationError) Key

Key function returns key value.

func (ExpressionValueValidationError) Reason

Reason function returns reason value.

type ExpressionValue_BoolValue

type ExpressionValue_BoolValue struct {
	// Represents a boolean value.
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type ExpressionValue_DoubleValue

type ExpressionValue_DoubleValue struct {
	// Represents a double value.
	DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type ExpressionValue_IntValue

type ExpressionValue_IntValue struct {
	// Represents an integer value.
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ExpressionValue_StringValue

type ExpressionValue_StringValue struct {
	// Represents a string value.
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type FaasServiceClient

type FaasServiceClient interface {
	// Begin streaming triggers/response to/from the membrane
	TriggerStream(ctx context.Context, opts ...grpc.CallOption) (FaasService_TriggerStreamClient, error)
}

FaasServiceClient is the client API for FaasService 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.

type FaasServiceServer

type FaasServiceServer interface {
	// Begin streaming triggers/response to/from the membrane
	TriggerStream(FaasService_TriggerStreamServer) error
	// contains filtered or unexported methods
}

FaasServiceServer is the server API for FaasService service. All implementations must embed UnimplementedFaasServiceServer for forward compatibility

type FaasService_TriggerStreamClient

type FaasService_TriggerStreamClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type FaasService_TriggerStreamServer

type FaasService_TriggerStreamServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type FailedTask

type FailedTask struct {

	// The task that failed to be pushed
	Task *NitricTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// A message describing the failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*FailedTask) Descriptor deprecated

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

Deprecated: Use FailedTask.ProtoReflect.Descriptor instead.

func (*FailedTask) GetMessage

func (x *FailedTask) GetMessage() string

func (*FailedTask) GetTask

func (x *FailedTask) GetTask() *NitricTask

func (*FailedTask) ProtoMessage

func (*FailedTask) ProtoMessage()

func (*FailedTask) ProtoReflect

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

func (*FailedTask) Reset

func (x *FailedTask) Reset()

func (*FailedTask) String

func (x *FailedTask) String() string

func (*FailedTask) Validate

func (m *FailedTask) Validate() error

Validate checks the field values on FailedTask with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FailedTask) ValidateAll

func (m *FailedTask) ValidateAll() error

ValidateAll checks the field values on FailedTask with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FailedTaskMultiError, or nil if none found.

type FailedTaskMultiError

type FailedTaskMultiError []error

FailedTaskMultiError is an error wrapping multiple validation errors returned by FailedTask.ValidateAll() if the designated constraints aren't met.

func (FailedTaskMultiError) AllErrors

func (m FailedTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FailedTaskMultiError) Error

func (m FailedTaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FailedTaskValidationError

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

FailedTaskValidationError is the validation error returned by FailedTask.Validate if the designated constraints aren't met.

func (FailedTaskValidationError) Cause

func (e FailedTaskValidationError) Cause() error

Cause function returns cause value.

func (FailedTaskValidationError) Error

Error satisfies the builtin error interface

func (FailedTaskValidationError) ErrorName

func (e FailedTaskValidationError) ErrorName() string

ErrorName returns error name.

func (FailedTaskValidationError) Field

Field function returns field value.

func (FailedTaskValidationError) Key

Key function returns key value.

func (FailedTaskValidationError) Reason

func (e FailedTaskValidationError) Reason() string

Reason function returns reason value.

type File added in v0.16.0

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

func (*File) Descriptor deprecated added in v0.16.0

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetKey added in v0.16.0

func (x *File) GetKey() string

func (*File) ProtoMessage added in v0.16.0

func (*File) ProtoMessage()

func (*File) ProtoReflect added in v0.16.0

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

func (*File) Reset added in v0.16.0

func (x *File) Reset()

func (*File) String added in v0.16.0

func (x *File) String() string

func (*File) Validate added in v0.16.0

func (m *File) Validate() error

Validate checks the field values on File with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*File) ValidateAll added in v0.16.0

func (m *File) ValidateAll() error

ValidateAll checks the field values on File with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FileMultiError, or nil if none found.

type FileMultiError added in v0.16.0

type FileMultiError []error

FileMultiError is an error wrapping multiple validation errors returned by File.ValidateAll() if the designated constraints aren't met.

func (FileMultiError) AllErrors added in v0.16.0

func (m FileMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FileMultiError) Error added in v0.16.0

func (m FileMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FileValidationError added in v0.16.0

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

FileValidationError is the validation error returned by File.Validate if the designated constraints aren't met.

func (FileValidationError) Cause added in v0.16.0

func (e FileValidationError) Cause() error

Cause function returns cause value.

func (FileValidationError) Error added in v0.16.0

func (e FileValidationError) Error() string

Error satisfies the builtin error interface

func (FileValidationError) ErrorName added in v0.16.0

func (e FileValidationError) ErrorName() string

ErrorName returns error name.

func (FileValidationError) Field added in v0.16.0

func (e FileValidationError) Field() string

Field function returns field value.

func (FileValidationError) Key added in v0.16.0

func (e FileValidationError) Key() bool

Key function returns key value.

func (FileValidationError) Reason added in v0.16.0

func (e FileValidationError) Reason() string

Reason function returns reason value.

type HeaderValue

type HeaderValue struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*HeaderValue) Descriptor deprecated

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

Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.

func (*HeaderValue) GetValue

func (x *HeaderValue) GetValue() []string

func (*HeaderValue) ProtoMessage

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) ProtoReflect

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

func (*HeaderValue) Reset

func (x *HeaderValue) Reset()

func (*HeaderValue) String

func (x *HeaderValue) String() string

func (*HeaderValue) Validate

func (m *HeaderValue) Validate() error

Validate checks the field values on HeaderValue with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*HeaderValue) ValidateAll

func (m *HeaderValue) ValidateAll() error

ValidateAll checks the field values on HeaderValue with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HeaderValueMultiError, or nil if none found.

type HeaderValueMultiError

type HeaderValueMultiError []error

HeaderValueMultiError is an error wrapping multiple validation errors returned by HeaderValue.ValidateAll() if the designated constraints aren't met.

func (HeaderValueMultiError) AllErrors

func (m HeaderValueMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HeaderValueMultiError) Error

func (m HeaderValueMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type HeaderValueValidationError

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

HeaderValueValidationError is the validation error returned by HeaderValue.Validate if the designated constraints aren't met.

func (HeaderValueValidationError) Cause

Cause function returns cause value.

func (HeaderValueValidationError) Error

Error satisfies the builtin error interface

func (HeaderValueValidationError) ErrorName

func (e HeaderValueValidationError) ErrorName() string

ErrorName returns error name.

func (HeaderValueValidationError) Field

Field function returns field value.

func (HeaderValueValidationError) Key

Key function returns key value.

func (HeaderValueValidationError) Reason

Reason function returns reason value.

type HttpResponseContext

type HttpResponseContext struct {

	// Old HTTP response headers (deprecated)
	// TODO: Remove in 1.0
	//
	// Deprecated: Do not use.
	HeadersOld map[string]string `` /* 179-byte string literal not displayed */
	// The HTTP status of the request
	Status int32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// HTTP response headers
	Headers map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Specific HttpResponse message Note this does not have to be handled by the User at all but they will have the option of control If they choose...

func (*HttpResponseContext) Descriptor deprecated

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

Deprecated: Use HttpResponseContext.ProtoReflect.Descriptor instead.

func (*HttpResponseContext) GetHeaders

func (x *HttpResponseContext) GetHeaders() map[string]*HeaderValue

func (*HttpResponseContext) GetHeadersOld deprecated

func (x *HttpResponseContext) GetHeadersOld() map[string]string

Deprecated: Do not use.

func (*HttpResponseContext) GetStatus

func (x *HttpResponseContext) GetStatus() int32

func (*HttpResponseContext) ProtoMessage

func (*HttpResponseContext) ProtoMessage()

func (*HttpResponseContext) ProtoReflect

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

func (*HttpResponseContext) Reset

func (x *HttpResponseContext) Reset()

func (*HttpResponseContext) String

func (x *HttpResponseContext) String() string

func (*HttpResponseContext) Validate

func (m *HttpResponseContext) Validate() error

Validate checks the field values on HttpResponseContext with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*HttpResponseContext) ValidateAll

func (m *HttpResponseContext) ValidateAll() error

ValidateAll checks the field values on HttpResponseContext with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HttpResponseContextMultiError, or nil if none found.

type HttpResponseContextMultiError

type HttpResponseContextMultiError []error

HttpResponseContextMultiError is an error wrapping multiple validation errors returned by HttpResponseContext.ValidateAll() if the designated constraints aren't met.

func (HttpResponseContextMultiError) AllErrors

func (m HttpResponseContextMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HttpResponseContextMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type HttpResponseContextValidationError

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

HttpResponseContextValidationError is the validation error returned by HttpResponseContext.Validate if the designated constraints aren't met.

func (HttpResponseContextValidationError) Cause

Cause function returns cause value.

func (HttpResponseContextValidationError) Error

Error satisfies the builtin error interface

func (HttpResponseContextValidationError) ErrorName

ErrorName returns error name.

func (HttpResponseContextValidationError) Field

Field function returns field value.

func (HttpResponseContextValidationError) Key

Key function returns key value.

func (HttpResponseContextValidationError) Reason

Reason function returns reason value.

type HttpTriggerContext

type HttpTriggerContext struct {

	// The request method
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// The path of the request
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// The old request headers (preserving for backwards compatibility)
	// TODO: Remove in 1.0
	//
	// Deprecated: Do not use.
	HeadersOld map[string]string `` /* 179-byte string literal not displayed */
	// The old query params (preserving for backwards compatibility)
	// TODO: Remove in 1.0
	//
	// Deprecated: Do not use.
	QueryParamsOld map[string]string `` /* 193-byte string literal not displayed */
	// HTTP request headers
	Headers map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	// HTTP Query params
	QueryParams map[string]*QueryValue `` /* 182-byte string literal not displayed */
	// HTTP Path parameters
	PathParams map[string]string `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HttpTriggerContext) Descriptor deprecated

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

Deprecated: Use HttpTriggerContext.ProtoReflect.Descriptor instead.

func (*HttpTriggerContext) GetHeaders

func (x *HttpTriggerContext) GetHeaders() map[string]*HeaderValue

func (*HttpTriggerContext) GetHeadersOld deprecated

func (x *HttpTriggerContext) GetHeadersOld() map[string]string

Deprecated: Do not use.

func (*HttpTriggerContext) GetMethod

func (x *HttpTriggerContext) GetMethod() string

func (*HttpTriggerContext) GetPath

func (x *HttpTriggerContext) GetPath() string

func (*HttpTriggerContext) GetPathParams

func (x *HttpTriggerContext) GetPathParams() map[string]string

func (*HttpTriggerContext) GetQueryParams

func (x *HttpTriggerContext) GetQueryParams() map[string]*QueryValue

func (*HttpTriggerContext) GetQueryParamsOld deprecated

func (x *HttpTriggerContext) GetQueryParamsOld() map[string]string

Deprecated: Do not use.

func (*HttpTriggerContext) ProtoMessage

func (*HttpTriggerContext) ProtoMessage()

func (*HttpTriggerContext) ProtoReflect

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

func (*HttpTriggerContext) Reset

func (x *HttpTriggerContext) Reset()

func (*HttpTriggerContext) String

func (x *HttpTriggerContext) String() string

func (*HttpTriggerContext) Validate

func (m *HttpTriggerContext) Validate() error

Validate checks the field values on HttpTriggerContext with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*HttpTriggerContext) ValidateAll

func (m *HttpTriggerContext) ValidateAll() error

ValidateAll checks the field values on HttpTriggerContext with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HttpTriggerContextMultiError, or nil if none found.

type HttpTriggerContextMultiError

type HttpTriggerContextMultiError []error

HttpTriggerContextMultiError is an error wrapping multiple validation errors returned by HttpTriggerContext.ValidateAll() if the designated constraints aren't met.

func (HttpTriggerContextMultiError) AllErrors

func (m HttpTriggerContextMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HttpTriggerContextMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type HttpTriggerContextValidationError

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

HttpTriggerContextValidationError is the validation error returned by HttpTriggerContext.Validate if the designated constraints aren't met.

func (HttpTriggerContextValidationError) Cause

Cause function returns cause value.

func (HttpTriggerContextValidationError) Error

Error satisfies the builtin error interface

func (HttpTriggerContextValidationError) ErrorName

ErrorName returns error name.

func (HttpTriggerContextValidationError) Field

Field function returns field value.

func (HttpTriggerContextValidationError) Key

Key function returns key value.

func (HttpTriggerContextValidationError) Reason

Reason function returns reason value.

type InitRequest

type InitRequest struct {

	// The type of worker we are registering
	//
	// Types that are assignable to Worker:
	//
	//	*InitRequest_Api
	//	*InitRequest_Subscription
	//	*InitRequest_Schedule
	Worker isInitRequest_Worker `protobuf_oneof:"Worker"`
	// contains filtered or unexported fields
}

InitRequest - Identifies a worker as ready to recieve triggers This message will contain information on the type of triggers that a worker is capable of handling

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetApi

func (x *InitRequest) GetApi() *ApiWorker

func (*InitRequest) GetSchedule

func (x *InitRequest) GetSchedule() *ScheduleWorker

func (*InitRequest) GetSubscription

func (x *InitRequest) GetSubscription() *SubscriptionWorker

func (*InitRequest) GetWorker

func (m *InitRequest) GetWorker() isInitRequest_Worker

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

func (*InitRequest) Validate

func (m *InitRequest) Validate() error

Validate checks the field values on InitRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*InitRequest) ValidateAll

func (m *InitRequest) ValidateAll() error

ValidateAll checks the field values on InitRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InitRequestMultiError, or nil if none found.

type InitRequestMultiError

type InitRequestMultiError []error

InitRequestMultiError is an error wrapping multiple validation errors returned by InitRequest.ValidateAll() if the designated constraints aren't met.

func (InitRequestMultiError) AllErrors

func (m InitRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InitRequestMultiError) Error

func (m InitRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InitRequestValidationError

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

InitRequestValidationError is the validation error returned by InitRequest.Validate if the designated constraints aren't met.

func (InitRequestValidationError) Cause

Cause function returns cause value.

func (InitRequestValidationError) Error

Error satisfies the builtin error interface

func (InitRequestValidationError) ErrorName

func (e InitRequestValidationError) ErrorName() string

ErrorName returns error name.

func (InitRequestValidationError) Field

Field function returns field value.

func (InitRequestValidationError) Key

Key function returns key value.

func (InitRequestValidationError) Reason

Reason function returns reason value.

type InitRequest_Api

type InitRequest_Api struct {
	Api *ApiWorker `protobuf:"bytes,10,opt,name=api,proto3,oneof"`
}

type InitRequest_Schedule

type InitRequest_Schedule struct {
	Schedule *ScheduleWorker `protobuf:"bytes,12,opt,name=schedule,proto3,oneof"`
}

type InitRequest_Subscription

type InitRequest_Subscription struct {
	Subscription *SubscriptionWorker `protobuf:"bytes,11,opt,name=subscription,proto3,oneof"`
}

type InitResponse

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

Placeholder message

func (*InitResponse) Descriptor deprecated

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) ProtoMessage

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect

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

func (*InitResponse) Reset

func (x *InitResponse) Reset()

func (*InitResponse) String

func (x *InitResponse) String() string

func (*InitResponse) Validate

func (m *InitResponse) Validate() error

Validate checks the field values on InitResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*InitResponse) ValidateAll

func (m *InitResponse) ValidateAll() error

ValidateAll checks the field values on InitResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InitResponseMultiError, or nil if none found.

type InitResponseMultiError

type InitResponseMultiError []error

InitResponseMultiError is an error wrapping multiple validation errors returned by InitResponse.ValidateAll() if the designated constraints aren't met.

func (InitResponseMultiError) AllErrors

func (m InitResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InitResponseMultiError) Error

func (m InitResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InitResponseValidationError

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

InitResponseValidationError is the validation error returned by InitResponse.Validate if the designated constraints aren't met.

func (InitResponseValidationError) Cause

Cause function returns cause value.

func (InitResponseValidationError) Error

Error satisfies the builtin error interface

func (InitResponseValidationError) ErrorName

func (e InitResponseValidationError) ErrorName() string

ErrorName returns error name.

func (InitResponseValidationError) Field

Field function returns field value.

func (InitResponseValidationError) Key

Key function returns key value.

func (InitResponseValidationError) Reason

Reason function returns reason value.

type Key

type Key struct {

	// The item collection
	Collection *Collection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// The items unique id
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Provides a document identifying key type

func (*Key) Descriptor deprecated

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetCollection

func (x *Key) GetCollection() *Collection

func (*Key) GetId

func (x *Key) GetId() string

func (*Key) ProtoMessage

func (*Key) ProtoMessage()

func (*Key) ProtoReflect

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

func (*Key) Reset

func (x *Key) Reset()

func (*Key) String

func (x *Key) String() string

func (*Key) Validate

func (m *Key) Validate() error

Validate checks the field values on Key with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Key) ValidateAll

func (m *Key) ValidateAll() error

ValidateAll checks the field values on Key with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KeyMultiError, or nil if none found.

type KeyMultiError

type KeyMultiError []error

KeyMultiError is an error wrapping multiple validation errors returned by Key.ValidateAll() if the designated constraints aren't met.

func (KeyMultiError) AllErrors

func (m KeyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyMultiError) Error

func (m KeyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type KeyValidationError

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

KeyValidationError is the validation error returned by Key.Validate if the designated constraints aren't met.

func (KeyValidationError) Cause

func (e KeyValidationError) Cause() error

Cause function returns cause value.

func (KeyValidationError) Error

func (e KeyValidationError) Error() string

Error satisfies the builtin error interface

func (KeyValidationError) ErrorName

func (e KeyValidationError) ErrorName() string

ErrorName returns error name.

func (KeyValidationError) Field

func (e KeyValidationError) Field() string

Field function returns field value.

func (KeyValidationError) Key

func (e KeyValidationError) Key() bool

Key function returns key value.

func (KeyValidationError) Reason

func (e KeyValidationError) Reason() string

Reason function returns reason value.

type NitricEvent

type NitricEvent struct {

	// A Unique ID for the Nitric Event
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A content hint for the events payload
	PayloadType string `protobuf:"bytes,2,opt,name=payload_type,json=payloadType,proto3" json:"payload_type,omitempty"`
	// The payload of the event
	Payload *structpb.Struct `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

Nitric Event Model

func (*NitricEvent) Descriptor deprecated

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

Deprecated: Use NitricEvent.ProtoReflect.Descriptor instead.

func (*NitricEvent) GetId

func (x *NitricEvent) GetId() string

func (*NitricEvent) GetPayload

func (x *NitricEvent) GetPayload() *structpb.Struct

func (*NitricEvent) GetPayloadType

func (x *NitricEvent) GetPayloadType() string

func (*NitricEvent) ProtoMessage

func (*NitricEvent) ProtoMessage()

func (*NitricEvent) ProtoReflect

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

func (*NitricEvent) Reset

func (x *NitricEvent) Reset()

func (*NitricEvent) String

func (x *NitricEvent) String() string

func (*NitricEvent) Validate

func (m *NitricEvent) Validate() error

Validate checks the field values on NitricEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NitricEvent) ValidateAll

func (m *NitricEvent) ValidateAll() error

ValidateAll checks the field values on NitricEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NitricEventMultiError, or nil if none found.

type NitricEventMultiError

type NitricEventMultiError []error

NitricEventMultiError is an error wrapping multiple validation errors returned by NitricEvent.ValidateAll() if the designated constraints aren't met.

func (NitricEventMultiError) AllErrors

func (m NitricEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NitricEventMultiError) Error

func (m NitricEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NitricEventValidationError

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

NitricEventValidationError is the validation error returned by NitricEvent.Validate if the designated constraints aren't met.

func (NitricEventValidationError) Cause

Cause function returns cause value.

func (NitricEventValidationError) Error

Error satisfies the builtin error interface

func (NitricEventValidationError) ErrorName

func (e NitricEventValidationError) ErrorName() string

ErrorName returns error name.

func (NitricEventValidationError) Field

Field function returns field value.

func (NitricEventValidationError) Key

Key function returns key value.

func (NitricEventValidationError) Reason

Reason function returns reason value.

type NitricTask

type NitricTask struct {

	// A unique id for the task
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The lease id unique to the pop request, this must be used to complete, extend the lease or release the task.
	LeaseId string `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// A content hint for the tasks payload
	PayloadType string `protobuf:"bytes,3,opt,name=payload_type,json=payloadType,proto3" json:"payload_type,omitempty"`
	// The payload of the task
	Payload *structpb.Struct `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

A task to be sent or received from a queue.

func (*NitricTask) Descriptor deprecated

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

Deprecated: Use NitricTask.ProtoReflect.Descriptor instead.

func (*NitricTask) GetId

func (x *NitricTask) GetId() string

func (*NitricTask) GetLeaseId

func (x *NitricTask) GetLeaseId() string

func (*NitricTask) GetPayload

func (x *NitricTask) GetPayload() *structpb.Struct

func (*NitricTask) GetPayloadType

func (x *NitricTask) GetPayloadType() string

func (*NitricTask) ProtoMessage

func (*NitricTask) ProtoMessage()

func (*NitricTask) ProtoReflect

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

func (*NitricTask) Reset

func (x *NitricTask) Reset()

func (*NitricTask) String

func (x *NitricTask) String() string

func (*NitricTask) Validate

func (m *NitricTask) Validate() error

Validate checks the field values on NitricTask with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NitricTask) ValidateAll

func (m *NitricTask) ValidateAll() error

ValidateAll checks the field values on NitricTask with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NitricTaskMultiError, or nil if none found.

type NitricTaskMultiError

type NitricTaskMultiError []error

NitricTaskMultiError is an error wrapping multiple validation errors returned by NitricTask.ValidateAll() if the designated constraints aren't met.

func (NitricTaskMultiError) AllErrors

func (m NitricTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NitricTaskMultiError) Error

func (m NitricTaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NitricTaskValidationError

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

NitricTaskValidationError is the validation error returned by NitricTask.Validate if the designated constraints aren't met.

func (NitricTaskValidationError) Cause

func (e NitricTaskValidationError) Cause() error

Cause function returns cause value.

func (NitricTaskValidationError) Error

Error satisfies the builtin error interface

func (NitricTaskValidationError) ErrorName

func (e NitricTaskValidationError) ErrorName() string

ErrorName returns error name.

func (NitricTaskValidationError) Field

Field function returns field value.

func (NitricTaskValidationError) Key

Key function returns key value.

func (NitricTaskValidationError) Reason

func (e NitricTaskValidationError) Reason() string

Reason function returns reason value.

type NitricTopic

type NitricTopic struct {

	// The Nitric name for the topic
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Represents an event topic

func (*NitricTopic) Descriptor deprecated

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

Deprecated: Use NitricTopic.ProtoReflect.Descriptor instead.

func (*NitricTopic) GetName

func (x *NitricTopic) GetName() string

func (*NitricTopic) ProtoMessage

func (*NitricTopic) ProtoMessage()

func (*NitricTopic) ProtoReflect

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

func (*NitricTopic) Reset

func (x *NitricTopic) Reset()

func (*NitricTopic) String

func (x *NitricTopic) String() string

func (*NitricTopic) Validate

func (m *NitricTopic) Validate() error

Validate checks the field values on NitricTopic with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NitricTopic) ValidateAll

func (m *NitricTopic) ValidateAll() error

ValidateAll checks the field values on NitricTopic with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NitricTopicMultiError, or nil if none found.

type NitricTopicMultiError

type NitricTopicMultiError []error

NitricTopicMultiError is an error wrapping multiple validation errors returned by NitricTopic.ValidateAll() if the designated constraints aren't met.

func (NitricTopicMultiError) AllErrors

func (m NitricTopicMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NitricTopicMultiError) Error

func (m NitricTopicMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NitricTopicValidationError

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

NitricTopicValidationError is the validation error returned by NitricTopic.Validate if the designated constraints aren't met.

func (NitricTopicValidationError) Cause

Cause function returns cause value.

func (NitricTopicValidationError) Error

Error satisfies the builtin error interface

func (NitricTopicValidationError) ErrorName

func (e NitricTopicValidationError) ErrorName() string

ErrorName returns error name.

func (NitricTopicValidationError) Field

Field function returns field value.

func (NitricTopicValidationError) Key

Key function returns key value.

func (NitricTopicValidationError) Reason

Reason function returns reason value.

type PolicyResource

type PolicyResource struct {
	Principals []*Resource `protobuf:"bytes,1,rep,name=principals,proto3" json:"principals,omitempty"`
	Actions    []Action    `protobuf:"varint,2,rep,packed,name=actions,proto3,enum=nitric.resource.v1.Action" json:"actions,omitempty"`
	Resources  []*Resource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyResource) Descriptor deprecated

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

Deprecated: Use PolicyResource.ProtoReflect.Descriptor instead.

func (*PolicyResource) GetActions

func (x *PolicyResource) GetActions() []Action

func (*PolicyResource) GetPrincipals

func (x *PolicyResource) GetPrincipals() []*Resource

func (*PolicyResource) GetResources

func (x *PolicyResource) GetResources() []*Resource

func (*PolicyResource) ProtoMessage

func (*PolicyResource) ProtoMessage()

func (*PolicyResource) ProtoReflect

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

func (*PolicyResource) Reset

func (x *PolicyResource) Reset()

func (*PolicyResource) String

func (x *PolicyResource) String() string

func (*PolicyResource) Validate

func (m *PolicyResource) Validate() error

Validate checks the field values on PolicyResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PolicyResource) ValidateAll

func (m *PolicyResource) ValidateAll() error

ValidateAll checks the field values on PolicyResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PolicyResourceMultiError, or nil if none found.

type PolicyResourceMultiError

type PolicyResourceMultiError []error

PolicyResourceMultiError is an error wrapping multiple validation errors returned by PolicyResource.ValidateAll() if the designated constraints aren't met.

func (PolicyResourceMultiError) AllErrors

func (m PolicyResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PolicyResourceMultiError) Error

func (m PolicyResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PolicyResourceValidationError

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

PolicyResourceValidationError is the validation error returned by PolicyResource.Validate if the designated constraints aren't met.

func (PolicyResourceValidationError) Cause

Cause function returns cause value.

func (PolicyResourceValidationError) Error

Error satisfies the builtin error interface

func (PolicyResourceValidationError) ErrorName

func (e PolicyResourceValidationError) ErrorName() string

ErrorName returns error name.

func (PolicyResourceValidationError) Field

Field function returns field value.

func (PolicyResourceValidationError) Key

Key function returns key value.

func (PolicyResourceValidationError) Reason

Reason function returns reason value.

type QueryValue

type QueryValue struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryValue) Descriptor deprecated

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

Deprecated: Use QueryValue.ProtoReflect.Descriptor instead.

func (*QueryValue) GetValue

func (x *QueryValue) GetValue() []string

func (*QueryValue) ProtoMessage

func (*QueryValue) ProtoMessage()

func (*QueryValue) ProtoReflect

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

func (*QueryValue) Reset

func (x *QueryValue) Reset()

func (*QueryValue) String

func (x *QueryValue) String() string

func (*QueryValue) Validate

func (m *QueryValue) Validate() error

Validate checks the field values on QueryValue with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueryValue) ValidateAll

func (m *QueryValue) ValidateAll() error

ValidateAll checks the field values on QueryValue with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueryValueMultiError, or nil if none found.

type QueryValueMultiError

type QueryValueMultiError []error

QueryValueMultiError is an error wrapping multiple validation errors returned by QueryValue.ValidateAll() if the designated constraints aren't met.

func (QueryValueMultiError) AllErrors

func (m QueryValueMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueryValueMultiError) Error

func (m QueryValueMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type QueryValueValidationError

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

QueryValueValidationError is the validation error returned by QueryValue.Validate if the designated constraints aren't met.

func (QueryValueValidationError) Cause

func (e QueryValueValidationError) Cause() error

Cause function returns cause value.

func (QueryValueValidationError) Error

Error satisfies the builtin error interface

func (QueryValueValidationError) ErrorName

func (e QueryValueValidationError) ErrorName() string

ErrorName returns error name.

func (QueryValueValidationError) Field

Field function returns field value.

func (QueryValueValidationError) Key

Key function returns key value.

func (QueryValueValidationError) Reason

func (e QueryValueValidationError) Reason() string

Reason function returns reason value.

type QueueCompleteRequest

type QueueCompleteRequest struct {

	// The nitric name for the queue
	//
	//	this will automatically be resolved to the provider specific queue identifier.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Lease id of the task to be completed
	LeaseId string `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueCompleteRequest) Descriptor deprecated

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

Deprecated: Use QueueCompleteRequest.ProtoReflect.Descriptor instead.

func (*QueueCompleteRequest) GetLeaseId

func (x *QueueCompleteRequest) GetLeaseId() string

func (*QueueCompleteRequest) GetQueue

func (x *QueueCompleteRequest) GetQueue() string

func (*QueueCompleteRequest) ProtoMessage

func (*QueueCompleteRequest) ProtoMessage()

func (*QueueCompleteRequest) ProtoReflect

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

func (*QueueCompleteRequest) Reset

func (x *QueueCompleteRequest) Reset()

func (*QueueCompleteRequest) String

func (x *QueueCompleteRequest) String() string

func (*QueueCompleteRequest) Validate

func (m *QueueCompleteRequest) Validate() error

Validate checks the field values on QueueCompleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueCompleteRequest) ValidateAll

func (m *QueueCompleteRequest) ValidateAll() error

ValidateAll checks the field values on QueueCompleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueCompleteRequestMultiError, or nil if none found.

type QueueCompleteRequestMultiError

type QueueCompleteRequestMultiError []error

QueueCompleteRequestMultiError is an error wrapping multiple validation errors returned by QueueCompleteRequest.ValidateAll() if the designated constraints aren't met.

func (QueueCompleteRequestMultiError) AllErrors

func (m QueueCompleteRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueCompleteRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueCompleteRequestValidationError

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

QueueCompleteRequestValidationError is the validation error returned by QueueCompleteRequest.Validate if the designated constraints aren't met.

func (QueueCompleteRequestValidationError) Cause

Cause function returns cause value.

func (QueueCompleteRequestValidationError) Error

Error satisfies the builtin error interface

func (QueueCompleteRequestValidationError) ErrorName

ErrorName returns error name.

func (QueueCompleteRequestValidationError) Field

Field function returns field value.

func (QueueCompleteRequestValidationError) Key

Key function returns key value.

func (QueueCompleteRequestValidationError) Reason

Reason function returns reason value.

type QueueCompleteResponse

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

func (*QueueCompleteResponse) Descriptor deprecated

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

Deprecated: Use QueueCompleteResponse.ProtoReflect.Descriptor instead.

func (*QueueCompleteResponse) ProtoMessage

func (*QueueCompleteResponse) ProtoMessage()

func (*QueueCompleteResponse) ProtoReflect

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

func (*QueueCompleteResponse) Reset

func (x *QueueCompleteResponse) Reset()

func (*QueueCompleteResponse) String

func (x *QueueCompleteResponse) String() string

func (*QueueCompleteResponse) Validate

func (m *QueueCompleteResponse) Validate() error

Validate checks the field values on QueueCompleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueCompleteResponse) ValidateAll

func (m *QueueCompleteResponse) ValidateAll() error

ValidateAll checks the field values on QueueCompleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueCompleteResponseMultiError, or nil if none found.

type QueueCompleteResponseMultiError

type QueueCompleteResponseMultiError []error

QueueCompleteResponseMultiError is an error wrapping multiple validation errors returned by QueueCompleteResponse.ValidateAll() if the designated constraints aren't met.

func (QueueCompleteResponseMultiError) AllErrors

func (m QueueCompleteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueCompleteResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueCompleteResponseValidationError

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

QueueCompleteResponseValidationError is the validation error returned by QueueCompleteResponse.Validate if the designated constraints aren't met.

func (QueueCompleteResponseValidationError) Cause

Cause function returns cause value.

func (QueueCompleteResponseValidationError) Error

Error satisfies the builtin error interface

func (QueueCompleteResponseValidationError) ErrorName

ErrorName returns error name.

func (QueueCompleteResponseValidationError) Field

Field function returns field value.

func (QueueCompleteResponseValidationError) Key

Key function returns key value.

func (QueueCompleteResponseValidationError) Reason

Reason function returns reason value.

type QueueReceiveRequest

type QueueReceiveRequest struct {

	// The nitric name for the queue
	// this will automatically be resolved to the provider specific queue identifier.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// The max number of items to pop off the queue, may be capped by provider specific limitations
	Depth int32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueReceiveRequest) Descriptor deprecated

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

Deprecated: Use QueueReceiveRequest.ProtoReflect.Descriptor instead.

func (*QueueReceiveRequest) GetDepth

func (x *QueueReceiveRequest) GetDepth() int32

func (*QueueReceiveRequest) GetQueue

func (x *QueueReceiveRequest) GetQueue() string

func (*QueueReceiveRequest) ProtoMessage

func (*QueueReceiveRequest) ProtoMessage()

func (*QueueReceiveRequest) ProtoReflect

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

func (*QueueReceiveRequest) Reset

func (x *QueueReceiveRequest) Reset()

func (*QueueReceiveRequest) String

func (x *QueueReceiveRequest) String() string

func (*QueueReceiveRequest) Validate

func (m *QueueReceiveRequest) Validate() error

Validate checks the field values on QueueReceiveRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueReceiveRequest) ValidateAll

func (m *QueueReceiveRequest) ValidateAll() error

ValidateAll checks the field values on QueueReceiveRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueReceiveRequestMultiError, or nil if none found.

type QueueReceiveRequestMultiError

type QueueReceiveRequestMultiError []error

QueueReceiveRequestMultiError is an error wrapping multiple validation errors returned by QueueReceiveRequest.ValidateAll() if the designated constraints aren't met.

func (QueueReceiveRequestMultiError) AllErrors

func (m QueueReceiveRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueReceiveRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueReceiveRequestValidationError

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

QueueReceiveRequestValidationError is the validation error returned by QueueReceiveRequest.Validate if the designated constraints aren't met.

func (QueueReceiveRequestValidationError) Cause

Cause function returns cause value.

func (QueueReceiveRequestValidationError) Error

Error satisfies the builtin error interface

func (QueueReceiveRequestValidationError) ErrorName

ErrorName returns error name.

func (QueueReceiveRequestValidationError) Field

Field function returns field value.

func (QueueReceiveRequestValidationError) Key

Key function returns key value.

func (QueueReceiveRequestValidationError) Reason

Reason function returns reason value.

type QueueReceiveResponse

type QueueReceiveResponse struct {

	// Array of tasks popped off the queue
	Tasks []*NitricTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueReceiveResponse) Descriptor deprecated

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

Deprecated: Use QueueReceiveResponse.ProtoReflect.Descriptor instead.

func (*QueueReceiveResponse) GetTasks

func (x *QueueReceiveResponse) GetTasks() []*NitricTask

func (*QueueReceiveResponse) ProtoMessage

func (*QueueReceiveResponse) ProtoMessage()

func (*QueueReceiveResponse) ProtoReflect

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

func (*QueueReceiveResponse) Reset

func (x *QueueReceiveResponse) Reset()

func (*QueueReceiveResponse) String

func (x *QueueReceiveResponse) String() string

func (*QueueReceiveResponse) Validate

func (m *QueueReceiveResponse) Validate() error

Validate checks the field values on QueueReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueReceiveResponse) ValidateAll

func (m *QueueReceiveResponse) ValidateAll() error

ValidateAll checks the field values on QueueReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueReceiveResponseMultiError, or nil if none found.

type QueueReceiveResponseMultiError

type QueueReceiveResponseMultiError []error

QueueReceiveResponseMultiError is an error wrapping multiple validation errors returned by QueueReceiveResponse.ValidateAll() if the designated constraints aren't met.

func (QueueReceiveResponseMultiError) AllErrors

func (m QueueReceiveResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueReceiveResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueReceiveResponseValidationError

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

QueueReceiveResponseValidationError is the validation error returned by QueueReceiveResponse.Validate if the designated constraints aren't met.

func (QueueReceiveResponseValidationError) Cause

Cause function returns cause value.

func (QueueReceiveResponseValidationError) Error

Error satisfies the builtin error interface

func (QueueReceiveResponseValidationError) ErrorName

ErrorName returns error name.

func (QueueReceiveResponseValidationError) Field

Field function returns field value.

func (QueueReceiveResponseValidationError) Key

Key function returns key value.

func (QueueReceiveResponseValidationError) Reason

Reason function returns reason value.

type QueueResource

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

func (*QueueResource) Descriptor deprecated

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

Deprecated: Use QueueResource.ProtoReflect.Descriptor instead.

func (*QueueResource) ProtoMessage

func (*QueueResource) ProtoMessage()

func (*QueueResource) ProtoReflect

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

func (*QueueResource) Reset

func (x *QueueResource) Reset()

func (*QueueResource) String

func (x *QueueResource) String() string

func (*QueueResource) Validate

func (m *QueueResource) Validate() error

Validate checks the field values on QueueResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueResource) ValidateAll

func (m *QueueResource) ValidateAll() error

ValidateAll checks the field values on QueueResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueResourceMultiError, or nil if none found.

type QueueResourceMultiError

type QueueResourceMultiError []error

QueueResourceMultiError is an error wrapping multiple validation errors returned by QueueResource.ValidateAll() if the designated constraints aren't met.

func (QueueResourceMultiError) AllErrors

func (m QueueResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueResourceMultiError) Error

func (m QueueResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type QueueResourceValidationError

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

QueueResourceValidationError is the validation error returned by QueueResource.Validate if the designated constraints aren't met.

func (QueueResourceValidationError) Cause

Cause function returns cause value.

func (QueueResourceValidationError) Error

Error satisfies the builtin error interface

func (QueueResourceValidationError) ErrorName

func (e QueueResourceValidationError) ErrorName() string

ErrorName returns error name.

func (QueueResourceValidationError) Field

Field function returns field value.

func (QueueResourceValidationError) Key

Key function returns key value.

func (QueueResourceValidationError) Reason

Reason function returns reason value.

type QueueSendBatchRequest

type QueueSendBatchRequest struct {

	// The Nitric name for the queue
	// this will automatically be resolved to the provider specific queue identifier.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Array of tasks to push to the queue
	Tasks []*NitricTask `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueSendBatchRequest) Descriptor deprecated

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

Deprecated: Use QueueSendBatchRequest.ProtoReflect.Descriptor instead.

func (*QueueSendBatchRequest) GetQueue

func (x *QueueSendBatchRequest) GetQueue() string

func (*QueueSendBatchRequest) GetTasks

func (x *QueueSendBatchRequest) GetTasks() []*NitricTask

func (*QueueSendBatchRequest) ProtoMessage

func (*QueueSendBatchRequest) ProtoMessage()

func (*QueueSendBatchRequest) ProtoReflect

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

func (*QueueSendBatchRequest) Reset

func (x *QueueSendBatchRequest) Reset()

func (*QueueSendBatchRequest) String

func (x *QueueSendBatchRequest) String() string

func (*QueueSendBatchRequest) Validate

func (m *QueueSendBatchRequest) Validate() error

Validate checks the field values on QueueSendBatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueSendBatchRequest) ValidateAll

func (m *QueueSendBatchRequest) ValidateAll() error

ValidateAll checks the field values on QueueSendBatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueSendBatchRequestMultiError, or nil if none found.

type QueueSendBatchRequestMultiError

type QueueSendBatchRequestMultiError []error

QueueSendBatchRequestMultiError is an error wrapping multiple validation errors returned by QueueSendBatchRequest.ValidateAll() if the designated constraints aren't met.

func (QueueSendBatchRequestMultiError) AllErrors

func (m QueueSendBatchRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueSendBatchRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueSendBatchRequestValidationError

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

QueueSendBatchRequestValidationError is the validation error returned by QueueSendBatchRequest.Validate if the designated constraints aren't met.

func (QueueSendBatchRequestValidationError) Cause

Cause function returns cause value.

func (QueueSendBatchRequestValidationError) Error

Error satisfies the builtin error interface

func (QueueSendBatchRequestValidationError) ErrorName

ErrorName returns error name.

func (QueueSendBatchRequestValidationError) Field

Field function returns field value.

func (QueueSendBatchRequestValidationError) Key

Key function returns key value.

func (QueueSendBatchRequestValidationError) Reason

Reason function returns reason value.

type QueueSendBatchResponse

type QueueSendBatchResponse struct {

	// A list of tasks that failed to be queued
	FailedTasks []*FailedTask `protobuf:"bytes,1,rep,name=failedTasks,proto3" json:"failedTasks,omitempty"`
	// contains filtered or unexported fields
}

Response for sending a collection of tasks

func (*QueueSendBatchResponse) Descriptor deprecated

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

Deprecated: Use QueueSendBatchResponse.ProtoReflect.Descriptor instead.

func (*QueueSendBatchResponse) GetFailedTasks

func (x *QueueSendBatchResponse) GetFailedTasks() []*FailedTask

func (*QueueSendBatchResponse) ProtoMessage

func (*QueueSendBatchResponse) ProtoMessage()

func (*QueueSendBatchResponse) ProtoReflect

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

func (*QueueSendBatchResponse) Reset

func (x *QueueSendBatchResponse) Reset()

func (*QueueSendBatchResponse) String

func (x *QueueSendBatchResponse) String() string

func (*QueueSendBatchResponse) Validate

func (m *QueueSendBatchResponse) Validate() error

Validate checks the field values on QueueSendBatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueSendBatchResponse) ValidateAll

func (m *QueueSendBatchResponse) ValidateAll() error

ValidateAll checks the field values on QueueSendBatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueSendBatchResponseMultiError, or nil if none found.

type QueueSendBatchResponseMultiError

type QueueSendBatchResponseMultiError []error

QueueSendBatchResponseMultiError is an error wrapping multiple validation errors returned by QueueSendBatchResponse.ValidateAll() if the designated constraints aren't met.

func (QueueSendBatchResponseMultiError) AllErrors

func (m QueueSendBatchResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueSendBatchResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueSendBatchResponseValidationError

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

QueueSendBatchResponseValidationError is the validation error returned by QueueSendBatchResponse.Validate if the designated constraints aren't met.

func (QueueSendBatchResponseValidationError) Cause

Cause function returns cause value.

func (QueueSendBatchResponseValidationError) Error

Error satisfies the builtin error interface

func (QueueSendBatchResponseValidationError) ErrorName

ErrorName returns error name.

func (QueueSendBatchResponseValidationError) Field

Field function returns field value.

func (QueueSendBatchResponseValidationError) Key

Key function returns key value.

func (QueueSendBatchResponseValidationError) Reason

Reason function returns reason value.

type QueueSendRequest

type QueueSendRequest struct {

	// The Nitric name for the queue
	// this will automatically be resolved to the provider specific queue identifier.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// The task to push to the queue
	Task *NitricTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

Request to push a single event to a queue

func (*QueueSendRequest) Descriptor deprecated

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

Deprecated: Use QueueSendRequest.ProtoReflect.Descriptor instead.

func (*QueueSendRequest) GetQueue

func (x *QueueSendRequest) GetQueue() string

func (*QueueSendRequest) GetTask

func (x *QueueSendRequest) GetTask() *NitricTask

func (*QueueSendRequest) ProtoMessage

func (*QueueSendRequest) ProtoMessage()

func (*QueueSendRequest) ProtoReflect

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

func (*QueueSendRequest) Reset

func (x *QueueSendRequest) Reset()

func (*QueueSendRequest) String

func (x *QueueSendRequest) String() string

func (*QueueSendRequest) Validate

func (m *QueueSendRequest) Validate() error

Validate checks the field values on QueueSendRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueSendRequest) ValidateAll

func (m *QueueSendRequest) ValidateAll() error

ValidateAll checks the field values on QueueSendRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueSendRequestMultiError, or nil if none found.

type QueueSendRequestMultiError

type QueueSendRequestMultiError []error

QueueSendRequestMultiError is an error wrapping multiple validation errors returned by QueueSendRequest.ValidateAll() if the designated constraints aren't met.

func (QueueSendRequestMultiError) AllErrors

func (m QueueSendRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueSendRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueSendRequestValidationError

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

QueueSendRequestValidationError is the validation error returned by QueueSendRequest.Validate if the designated constraints aren't met.

func (QueueSendRequestValidationError) Cause

Cause function returns cause value.

func (QueueSendRequestValidationError) Error

Error satisfies the builtin error interface

func (QueueSendRequestValidationError) ErrorName

ErrorName returns error name.

func (QueueSendRequestValidationError) Field

Field function returns field value.

func (QueueSendRequestValidationError) Key

Key function returns key value.

func (QueueSendRequestValidationError) Reason

Reason function returns reason value.

type QueueSendResponse

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

Result of pushing a single task to a queue

func (*QueueSendResponse) Descriptor deprecated

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

Deprecated: Use QueueSendResponse.ProtoReflect.Descriptor instead.

func (*QueueSendResponse) ProtoMessage

func (*QueueSendResponse) ProtoMessage()

func (*QueueSendResponse) ProtoReflect

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

func (*QueueSendResponse) Reset

func (x *QueueSendResponse) Reset()

func (*QueueSendResponse) String

func (x *QueueSendResponse) String() string

func (*QueueSendResponse) Validate

func (m *QueueSendResponse) Validate() error

Validate checks the field values on QueueSendResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QueueSendResponse) ValidateAll

func (m *QueueSendResponse) ValidateAll() error

ValidateAll checks the field values on QueueSendResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QueueSendResponseMultiError, or nil if none found.

type QueueSendResponseMultiError

type QueueSendResponseMultiError []error

QueueSendResponseMultiError is an error wrapping multiple validation errors returned by QueueSendResponse.ValidateAll() if the designated constraints aren't met.

func (QueueSendResponseMultiError) AllErrors

func (m QueueSendResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QueueSendResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type QueueSendResponseValidationError

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

QueueSendResponseValidationError is the validation error returned by QueueSendResponse.Validate if the designated constraints aren't met.

func (QueueSendResponseValidationError) Cause

Cause function returns cause value.

func (QueueSendResponseValidationError) Error

Error satisfies the builtin error interface

func (QueueSendResponseValidationError) ErrorName

ErrorName returns error name.

func (QueueSendResponseValidationError) Field

Field function returns field value.

func (QueueSendResponseValidationError) Key

Key function returns key value.

func (QueueSendResponseValidationError) Reason

Reason function returns reason value.

type QueueServiceClient

type QueueServiceClient interface {
	// Send a single event to a queue
	Send(ctx context.Context, in *QueueSendRequest, opts ...grpc.CallOption) (*QueueSendResponse, error)
	// Send multiple events to a queue
	SendBatch(ctx context.Context, in *QueueSendBatchRequest, opts ...grpc.CallOption) (*QueueSendBatchResponse, error)
	// Receive event(s) off a queue
	Receive(ctx context.Context, in *QueueReceiveRequest, opts ...grpc.CallOption) (*QueueReceiveResponse, error)
	// Complete an event previously popped from a queue
	Complete(ctx context.Context, in *QueueCompleteRequest, opts ...grpc.CallOption) (*QueueCompleteResponse, error)
}

QueueServiceClient is the client API for QueueService 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.

type QueueServiceServer

type QueueServiceServer interface {
	// Send a single event to a queue
	Send(context.Context, *QueueSendRequest) (*QueueSendResponse, error)
	// Send multiple events to a queue
	SendBatch(context.Context, *QueueSendBatchRequest) (*QueueSendBatchResponse, error)
	// Receive event(s) off a queue
	Receive(context.Context, *QueueReceiveRequest) (*QueueReceiveResponse, error)
	// Complete an event previously popped from a queue
	Complete(context.Context, *QueueCompleteRequest) (*QueueCompleteResponse, error)
	// contains filtered or unexported methods
}

QueueServiceServer is the server API for QueueService service. All implementations must embed UnimplementedQueueServiceServer for forward compatibility

type Resource

type Resource struct {
	Type ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=nitric.resource.v1.ResourceType" json:"type,omitempty"`
	Name string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetName

func (x *Resource) GetName() string

func (*Resource) GetType

func (x *Resource) GetType() ResourceType

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

func (*Resource) Validate

func (m *Resource) Validate() error

Validate checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Resource) ValidateAll

func (m *Resource) ValidateAll() error

ValidateAll checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceMultiError, or nil if none found.

type ResourceDeclareRequest

type ResourceDeclareRequest struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// Types that are assignable to Config:
	//
	//	*ResourceDeclareRequest_Policy
	//	*ResourceDeclareRequest_Bucket
	//	*ResourceDeclareRequest_Queue
	//	*ResourceDeclareRequest_Topic
	//	*ResourceDeclareRequest_Collection
	//	*ResourceDeclareRequest_Secret
	//	*ResourceDeclareRequest_Api
	Config isResourceDeclareRequest_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

func (*ResourceDeclareRequest) Descriptor deprecated

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

Deprecated: Use ResourceDeclareRequest.ProtoReflect.Descriptor instead.

func (*ResourceDeclareRequest) GetApi added in v0.17.0

func (x *ResourceDeclareRequest) GetApi() *ApiResource

func (*ResourceDeclareRequest) GetBucket

func (x *ResourceDeclareRequest) GetBucket() *BucketResource

func (*ResourceDeclareRequest) GetCollection

func (x *ResourceDeclareRequest) GetCollection() *CollectionResource

func (*ResourceDeclareRequest) GetConfig

func (m *ResourceDeclareRequest) GetConfig() isResourceDeclareRequest_Config

func (*ResourceDeclareRequest) GetPolicy

func (x *ResourceDeclareRequest) GetPolicy() *PolicyResource

func (*ResourceDeclareRequest) GetQueue

func (x *ResourceDeclareRequest) GetQueue() *QueueResource

func (*ResourceDeclareRequest) GetResource

func (x *ResourceDeclareRequest) GetResource() *Resource

func (*ResourceDeclareRequest) GetSecret added in v0.14.0

func (x *ResourceDeclareRequest) GetSecret() *SecretResource

func (*ResourceDeclareRequest) GetTopic

func (x *ResourceDeclareRequest) GetTopic() *TopicResource

func (*ResourceDeclareRequest) ProtoMessage

func (*ResourceDeclareRequest) ProtoMessage()

func (*ResourceDeclareRequest) ProtoReflect

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

func (*ResourceDeclareRequest) Reset

func (x *ResourceDeclareRequest) Reset()

func (*ResourceDeclareRequest) String

func (x *ResourceDeclareRequest) String() string

func (*ResourceDeclareRequest) Validate

func (m *ResourceDeclareRequest) Validate() error

Validate checks the field values on ResourceDeclareRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ResourceDeclareRequest) ValidateAll

func (m *ResourceDeclareRequest) ValidateAll() error

ValidateAll checks the field values on ResourceDeclareRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceDeclareRequestMultiError, or nil if none found.

type ResourceDeclareRequestMultiError

type ResourceDeclareRequestMultiError []error

ResourceDeclareRequestMultiError is an error wrapping multiple validation errors returned by ResourceDeclareRequest.ValidateAll() if the designated constraints aren't met.

func (ResourceDeclareRequestMultiError) AllErrors

func (m ResourceDeclareRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceDeclareRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ResourceDeclareRequestValidationError

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

ResourceDeclareRequestValidationError is the validation error returned by ResourceDeclareRequest.Validate if the designated constraints aren't met.

func (ResourceDeclareRequestValidationError) Cause

Cause function returns cause value.

func (ResourceDeclareRequestValidationError) Error

Error satisfies the builtin error interface

func (ResourceDeclareRequestValidationError) ErrorName

ErrorName returns error name.

func (ResourceDeclareRequestValidationError) Field

Field function returns field value.

func (ResourceDeclareRequestValidationError) Key

Key function returns key value.

func (ResourceDeclareRequestValidationError) Reason

Reason function returns reason value.

type ResourceDeclareRequest_Api added in v0.17.0

type ResourceDeclareRequest_Api struct {
	Api *ApiResource `protobuf:"bytes,16,opt,name=api,proto3,oneof"`
}

type ResourceDeclareRequest_Bucket

type ResourceDeclareRequest_Bucket struct {
	Bucket *BucketResource `protobuf:"bytes,11,opt,name=bucket,proto3,oneof"`
}

type ResourceDeclareRequest_Collection

type ResourceDeclareRequest_Collection struct {
	Collection *CollectionResource `protobuf:"bytes,14,opt,name=collection,proto3,oneof"`
}

type ResourceDeclareRequest_Policy

type ResourceDeclareRequest_Policy struct {
	Policy *PolicyResource `protobuf:"bytes,10,opt,name=policy,proto3,oneof"`
}

type ResourceDeclareRequest_Queue

type ResourceDeclareRequest_Queue struct {
	Queue *QueueResource `protobuf:"bytes,12,opt,name=queue,proto3,oneof"`
}

type ResourceDeclareRequest_Secret added in v0.14.0

type ResourceDeclareRequest_Secret struct {
	Secret *SecretResource `protobuf:"bytes,15,opt,name=secret,proto3,oneof"`
}

type ResourceDeclareRequest_Topic

type ResourceDeclareRequest_Topic struct {
	Topic *TopicResource `protobuf:"bytes,13,opt,name=topic,proto3,oneof"`
}

type ResourceDeclareResponse

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

func (*ResourceDeclareResponse) Descriptor deprecated

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

Deprecated: Use ResourceDeclareResponse.ProtoReflect.Descriptor instead.

func (*ResourceDeclareResponse) ProtoMessage

func (*ResourceDeclareResponse) ProtoMessage()

func (*ResourceDeclareResponse) ProtoReflect

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

func (*ResourceDeclareResponse) Reset

func (x *ResourceDeclareResponse) Reset()

func (*ResourceDeclareResponse) String

func (x *ResourceDeclareResponse) String() string

func (*ResourceDeclareResponse) Validate

func (m *ResourceDeclareResponse) Validate() error

Validate checks the field values on ResourceDeclareResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ResourceDeclareResponse) ValidateAll

func (m *ResourceDeclareResponse) ValidateAll() error

ValidateAll checks the field values on ResourceDeclareResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceDeclareResponseMultiError, or nil if none found.

type ResourceDeclareResponseMultiError

type ResourceDeclareResponseMultiError []error

ResourceDeclareResponseMultiError is an error wrapping multiple validation errors returned by ResourceDeclareResponse.ValidateAll() if the designated constraints aren't met.

func (ResourceDeclareResponseMultiError) AllErrors

func (m ResourceDeclareResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceDeclareResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ResourceDeclareResponseValidationError

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

ResourceDeclareResponseValidationError is the validation error returned by ResourceDeclareResponse.Validate if the designated constraints aren't met.

func (ResourceDeclareResponseValidationError) Cause

Cause function returns cause value.

func (ResourceDeclareResponseValidationError) Error

Error satisfies the builtin error interface

func (ResourceDeclareResponseValidationError) ErrorName

ErrorName returns error name.

func (ResourceDeclareResponseValidationError) Field

Field function returns field value.

func (ResourceDeclareResponseValidationError) Key

Key function returns key value.

func (ResourceDeclareResponseValidationError) Reason

Reason function returns reason value.

type ResourceDetailsRequest added in v0.20.0

type ResourceDetailsRequest struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceDetailsRequest) Descriptor deprecated added in v0.20.0

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

Deprecated: Use ResourceDetailsRequest.ProtoReflect.Descriptor instead.

func (*ResourceDetailsRequest) GetResource added in v0.20.0

func (x *ResourceDetailsRequest) GetResource() *Resource

func (*ResourceDetailsRequest) ProtoMessage added in v0.20.0

func (*ResourceDetailsRequest) ProtoMessage()

func (*ResourceDetailsRequest) ProtoReflect added in v0.20.0

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

func (*ResourceDetailsRequest) Reset added in v0.20.0

func (x *ResourceDetailsRequest) Reset()

func (*ResourceDetailsRequest) String added in v0.20.0

func (x *ResourceDetailsRequest) String() string

func (*ResourceDetailsRequest) Validate added in v0.20.0

func (m *ResourceDetailsRequest) Validate() error

Validate checks the field values on ResourceDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ResourceDetailsRequest) ValidateAll added in v0.20.0

func (m *ResourceDetailsRequest) ValidateAll() error

ValidateAll checks the field values on ResourceDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceDetailsRequestMultiError, or nil if none found.

type ResourceDetailsRequestMultiError added in v0.20.0

type ResourceDetailsRequestMultiError []error

ResourceDetailsRequestMultiError is an error wrapping multiple validation errors returned by ResourceDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (ResourceDetailsRequestMultiError) AllErrors added in v0.20.0

func (m ResourceDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceDetailsRequestMultiError) Error added in v0.20.0

Error returns a concatenation of all the error messages it wraps.

type ResourceDetailsRequestValidationError added in v0.20.0

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

ResourceDetailsRequestValidationError is the validation error returned by ResourceDetailsRequest.Validate if the designated constraints aren't met.

func (ResourceDetailsRequestValidationError) Cause added in v0.20.0

Cause function returns cause value.

func (ResourceDetailsRequestValidationError) Error added in v0.20.0

Error satisfies the builtin error interface

func (ResourceDetailsRequestValidationError) ErrorName added in v0.20.0

ErrorName returns error name.

func (ResourceDetailsRequestValidationError) Field added in v0.20.0

Field function returns field value.

func (ResourceDetailsRequestValidationError) Key added in v0.20.0

Key function returns key value.

func (ResourceDetailsRequestValidationError) Reason added in v0.20.0

Reason function returns reason value.

type ResourceDetailsResponse added in v0.20.0

type ResourceDetailsResponse struct {

	// The identifier of the resource
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The provider this resource is deployed with (e.g. aws)
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// The service this resource is deployed on (e.g. ApiGateway)
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// Details about the resource
	//
	// Types that are assignable to Details:
	//
	//	*ResourceDetailsResponse_Api
	Details isResourceDetailsResponse_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

func (*ResourceDetailsResponse) Descriptor deprecated added in v0.20.0

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

Deprecated: Use ResourceDetailsResponse.ProtoReflect.Descriptor instead.

func (*ResourceDetailsResponse) GetApi added in v0.20.0

func (*ResourceDetailsResponse) GetDetails added in v0.20.0

func (m *ResourceDetailsResponse) GetDetails() isResourceDetailsResponse_Details

func (*ResourceDetailsResponse) GetId added in v0.20.0

func (x *ResourceDetailsResponse) GetId() string

func (*ResourceDetailsResponse) GetProvider added in v0.20.0

func (x *ResourceDetailsResponse) GetProvider() string

func (*ResourceDetailsResponse) GetService added in v0.20.0

func (x *ResourceDetailsResponse) GetService() string

func (*ResourceDetailsResponse) ProtoMessage added in v0.20.0

func (*ResourceDetailsResponse) ProtoMessage()

func (*ResourceDetailsResponse) ProtoReflect added in v0.20.0

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

func (*ResourceDetailsResponse) Reset added in v0.20.0

func (x *ResourceDetailsResponse) Reset()

func (*ResourceDetailsResponse) String added in v0.20.0

func (x *ResourceDetailsResponse) String() string

func (*ResourceDetailsResponse) Validate added in v0.20.0

func (m *ResourceDetailsResponse) Validate() error

Validate checks the field values on ResourceDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ResourceDetailsResponse) ValidateAll added in v0.20.0

func (m *ResourceDetailsResponse) ValidateAll() error

ValidateAll checks the field values on ResourceDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceDetailsResponseMultiError, or nil if none found.

type ResourceDetailsResponseMultiError added in v0.20.0

type ResourceDetailsResponseMultiError []error

ResourceDetailsResponseMultiError is an error wrapping multiple validation errors returned by ResourceDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (ResourceDetailsResponseMultiError) AllErrors added in v0.20.0

func (m ResourceDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceDetailsResponseMultiError) Error added in v0.20.0

Error returns a concatenation of all the error messages it wraps.

type ResourceDetailsResponseValidationError added in v0.20.0

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

ResourceDetailsResponseValidationError is the validation error returned by ResourceDetailsResponse.Validate if the designated constraints aren't met.

func (ResourceDetailsResponseValidationError) Cause added in v0.20.0

Cause function returns cause value.

func (ResourceDetailsResponseValidationError) Error added in v0.20.0

Error satisfies the builtin error interface

func (ResourceDetailsResponseValidationError) ErrorName added in v0.20.0

ErrorName returns error name.

func (ResourceDetailsResponseValidationError) Field added in v0.20.0

Field function returns field value.

func (ResourceDetailsResponseValidationError) Key added in v0.20.0

Key function returns key value.

func (ResourceDetailsResponseValidationError) Reason added in v0.20.0

Reason function returns reason value.

type ResourceDetailsResponse_Api added in v0.20.0

type ResourceDetailsResponse_Api struct {
	Api *ApiResourceDetails `protobuf:"bytes,10,opt,name=api,proto3,oneof"`
}

type ResourceMultiError

type ResourceMultiError []error

ResourceMultiError is an error wrapping multiple validation errors returned by Resource.ValidateAll() if the designated constraints aren't met.

func (ResourceMultiError) AllErrors

func (m ResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceMultiError) Error

func (m ResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ResourceServiceClient

type ResourceServiceClient interface {
	// Declare a resource for the nitric application
	// At Deploy time this will create resources as part of the nitric stacks dependency graph
	// At runtime
	Declare(ctx context.Context, in *ResourceDeclareRequest, opts ...grpc.CallOption) (*ResourceDeclareResponse, error)
	// Retrieve details about a resource at runtime
	Details(ctx context.Context, in *ResourceDetailsRequest, opts ...grpc.CallOption) (*ResourceDetailsResponse, error)
}

ResourceServiceClient is the client API for ResourceService 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.

type ResourceServiceServer

type ResourceServiceServer interface {
	// Declare a resource for the nitric application
	// At Deploy time this will create resources as part of the nitric stacks dependency graph
	// At runtime
	Declare(context.Context, *ResourceDeclareRequest) (*ResourceDeclareResponse, error)
	// Retrieve details about a resource at runtime
	Details(context.Context, *ResourceDetailsRequest) (*ResourceDetailsResponse, error)
	// contains filtered or unexported methods
}

ResourceServiceServer is the server API for ResourceService service. All implementations must embed UnimplementedResourceServiceServer for forward compatibility

type ResourceType

type ResourceType int32
const (
	ResourceType_Api          ResourceType = 0
	ResourceType_Function     ResourceType = 1
	ResourceType_Bucket       ResourceType = 2
	ResourceType_Queue        ResourceType = 3
	ResourceType_Topic        ResourceType = 4
	ResourceType_Schedule     ResourceType = 5
	ResourceType_Subscription ResourceType = 6
	ResourceType_Collection   ResourceType = 7
	ResourceType_Policy       ResourceType = 8
	ResourceType_Secret       ResourceType = 9
)

func (ResourceType) Descriptor

func (ResourceType) Enum

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number

func (ResourceType) String

func (x ResourceType) String() string

func (ResourceType) Type

type ResourceValidationError

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

ResourceValidationError is the validation error returned by Resource.Validate if the designated constraints aren't met.

func (ResourceValidationError) Cause

func (e ResourceValidationError) Cause() error

Cause function returns cause value.

func (ResourceValidationError) Error

func (e ResourceValidationError) Error() string

Error satisfies the builtin error interface

func (ResourceValidationError) ErrorName

func (e ResourceValidationError) ErrorName() string

ErrorName returns error name.

func (ResourceValidationError) Field

func (e ResourceValidationError) Field() string

Field function returns field value.

func (ResourceValidationError) Key

func (e ResourceValidationError) Key() bool

Key function returns key value.

func (ResourceValidationError) Reason

func (e ResourceValidationError) Reason() string

Reason function returns reason value.

type ScheduleCron

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

func (*ScheduleCron) Descriptor deprecated

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

Deprecated: Use ScheduleCron.ProtoReflect.Descriptor instead.

func (*ScheduleCron) GetCron

func (x *ScheduleCron) GetCron() string

func (*ScheduleCron) ProtoMessage

func (*ScheduleCron) ProtoMessage()

func (*ScheduleCron) ProtoReflect

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

func (*ScheduleCron) Reset

func (x *ScheduleCron) Reset()

func (*ScheduleCron) String

func (x *ScheduleCron) String() string

func (*ScheduleCron) Validate

func (m *ScheduleCron) Validate() error

Validate checks the field values on ScheduleCron with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ScheduleCron) ValidateAll

func (m *ScheduleCron) ValidateAll() error

ValidateAll checks the field values on ScheduleCron with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ScheduleCronMultiError, or nil if none found.

type ScheduleCronMultiError

type ScheduleCronMultiError []error

ScheduleCronMultiError is an error wrapping multiple validation errors returned by ScheduleCron.ValidateAll() if the designated constraints aren't met.

func (ScheduleCronMultiError) AllErrors

func (m ScheduleCronMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ScheduleCronMultiError) Error

func (m ScheduleCronMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ScheduleCronValidationError

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

ScheduleCronValidationError is the validation error returned by ScheduleCron.Validate if the designated constraints aren't met.

func (ScheduleCronValidationError) Cause

Cause function returns cause value.

func (ScheduleCronValidationError) Error

Error satisfies the builtin error interface

func (ScheduleCronValidationError) ErrorName

func (e ScheduleCronValidationError) ErrorName() string

ErrorName returns error name.

func (ScheduleCronValidationError) Field

Field function returns field value.

func (ScheduleCronValidationError) Key

Key function returns key value.

func (ScheduleCronValidationError) Reason

Reason function returns reason value.

type ScheduleRate

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

func (*ScheduleRate) Descriptor deprecated

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

Deprecated: Use ScheduleRate.ProtoReflect.Descriptor instead.

func (*ScheduleRate) GetRate

func (x *ScheduleRate) GetRate() string

func (*ScheduleRate) ProtoMessage

func (*ScheduleRate) ProtoMessage()

func (*ScheduleRate) ProtoReflect

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

func (*ScheduleRate) Reset

func (x *ScheduleRate) Reset()

func (*ScheduleRate) String

func (x *ScheduleRate) String() string

func (*ScheduleRate) Validate

func (m *ScheduleRate) Validate() error

Validate checks the field values on ScheduleRate with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ScheduleRate) ValidateAll

func (m *ScheduleRate) ValidateAll() error

ValidateAll checks the field values on ScheduleRate with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ScheduleRateMultiError, or nil if none found.

type ScheduleRateMultiError

type ScheduleRateMultiError []error

ScheduleRateMultiError is an error wrapping multiple validation errors returned by ScheduleRate.ValidateAll() if the designated constraints aren't met.

func (ScheduleRateMultiError) AllErrors

func (m ScheduleRateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ScheduleRateMultiError) Error

func (m ScheduleRateMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ScheduleRateValidationError

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

ScheduleRateValidationError is the validation error returned by ScheduleRate.Validate if the designated constraints aren't met.

func (ScheduleRateValidationError) Cause

Cause function returns cause value.

func (ScheduleRateValidationError) Error

Error satisfies the builtin error interface

func (ScheduleRateValidationError) ErrorName

func (e ScheduleRateValidationError) ErrorName() string

ErrorName returns error name.

func (ScheduleRateValidationError) Field

Field function returns field value.

func (ScheduleRateValidationError) Key

Key function returns key value.

func (ScheduleRateValidationError) Reason

Reason function returns reason value.

type ScheduleWorker

type ScheduleWorker struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Cadence:
	//
	//	*ScheduleWorker_Rate
	//	*ScheduleWorker_Cron
	Cadence isScheduleWorker_Cadence `protobuf_oneof:"cadence"`
	// contains filtered or unexported fields
}

func (*ScheduleWorker) Descriptor deprecated

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

Deprecated: Use ScheduleWorker.ProtoReflect.Descriptor instead.

func (*ScheduleWorker) GetCadence

func (m *ScheduleWorker) GetCadence() isScheduleWorker_Cadence

func (*ScheduleWorker) GetCron

func (x *ScheduleWorker) GetCron() *ScheduleCron

func (*ScheduleWorker) GetKey

func (x *ScheduleWorker) GetKey() string

func (*ScheduleWorker) GetRate

func (x *ScheduleWorker) GetRate() *ScheduleRate

func (*ScheduleWorker) ProtoMessage

func (*ScheduleWorker) ProtoMessage()

func (*ScheduleWorker) ProtoReflect

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

func (*ScheduleWorker) Reset

func (x *ScheduleWorker) Reset()

func (*ScheduleWorker) String

func (x *ScheduleWorker) String() string

func (*ScheduleWorker) Validate

func (m *ScheduleWorker) Validate() error

Validate checks the field values on ScheduleWorker with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ScheduleWorker) ValidateAll

func (m *ScheduleWorker) ValidateAll() error

ValidateAll checks the field values on ScheduleWorker with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ScheduleWorkerMultiError, or nil if none found.

type ScheduleWorkerMultiError

type ScheduleWorkerMultiError []error

ScheduleWorkerMultiError is an error wrapping multiple validation errors returned by ScheduleWorker.ValidateAll() if the designated constraints aren't met.

func (ScheduleWorkerMultiError) AllErrors

func (m ScheduleWorkerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ScheduleWorkerMultiError) Error

func (m ScheduleWorkerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ScheduleWorkerValidationError

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

ScheduleWorkerValidationError is the validation error returned by ScheduleWorker.Validate if the designated constraints aren't met.

func (ScheduleWorkerValidationError) Cause

Cause function returns cause value.

func (ScheduleWorkerValidationError) Error

Error satisfies the builtin error interface

func (ScheduleWorkerValidationError) ErrorName

func (e ScheduleWorkerValidationError) ErrorName() string

ErrorName returns error name.

func (ScheduleWorkerValidationError) Field

Field function returns field value.

func (ScheduleWorkerValidationError) Key

Key function returns key value.

func (ScheduleWorkerValidationError) Reason

Reason function returns reason value.

type ScheduleWorker_Cron

type ScheduleWorker_Cron struct {
	Cron *ScheduleCron `protobuf:"bytes,11,opt,name=cron,proto3,oneof"`
}

type ScheduleWorker_Rate

type ScheduleWorker_Rate struct {
	Rate *ScheduleRate `protobuf:"bytes,10,opt,name=rate,proto3,oneof"`
}

type Secret

type Secret struct {

	// The secret name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

The secret container

func (*Secret) Descriptor deprecated

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetName

func (x *Secret) GetName() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

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

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

func (*Secret) Validate

func (m *Secret) Validate() error

Validate checks the field values on Secret with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Secret) ValidateAll

func (m *Secret) ValidateAll() error

ValidateAll checks the field values on Secret with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretMultiError, or nil if none found.

type SecretAccessRequest

type SecretAccessRequest struct {

	// The id of the secret
	SecretVersion *SecretVersion `protobuf:"bytes,1,opt,name=secret_version,json=secretVersion,proto3" json:"secret_version,omitempty"`
	// contains filtered or unexported fields
}

Request to get a secret from a Secret Store

func (*SecretAccessRequest) Descriptor deprecated

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

Deprecated: Use SecretAccessRequest.ProtoReflect.Descriptor instead.

func (*SecretAccessRequest) GetSecretVersion

func (x *SecretAccessRequest) GetSecretVersion() *SecretVersion

func (*SecretAccessRequest) ProtoMessage

func (*SecretAccessRequest) ProtoMessage()

func (*SecretAccessRequest) ProtoReflect

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

func (*SecretAccessRequest) Reset

func (x *SecretAccessRequest) Reset()

func (*SecretAccessRequest) String

func (x *SecretAccessRequest) String() string

func (*SecretAccessRequest) Validate

func (m *SecretAccessRequest) Validate() error

Validate checks the field values on SecretAccessRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretAccessRequest) ValidateAll

func (m *SecretAccessRequest) ValidateAll() error

ValidateAll checks the field values on SecretAccessRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretAccessRequestMultiError, or nil if none found.

type SecretAccessRequestMultiError

type SecretAccessRequestMultiError []error

SecretAccessRequestMultiError is an error wrapping multiple validation errors returned by SecretAccessRequest.ValidateAll() if the designated constraints aren't met.

func (SecretAccessRequestMultiError) AllErrors

func (m SecretAccessRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretAccessRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SecretAccessRequestValidationError

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

SecretAccessRequestValidationError is the validation error returned by SecretAccessRequest.Validate if the designated constraints aren't met.

func (SecretAccessRequestValidationError) Cause

Cause function returns cause value.

func (SecretAccessRequestValidationError) Error

Error satisfies the builtin error interface

func (SecretAccessRequestValidationError) ErrorName

ErrorName returns error name.

func (SecretAccessRequestValidationError) Field

Field function returns field value.

func (SecretAccessRequestValidationError) Key

Key function returns key value.

func (SecretAccessRequestValidationError) Reason

Reason function returns reason value.

type SecretAccessResponse

type SecretAccessResponse struct {

	// The version of the secret that was requested
	SecretVersion *SecretVersion `protobuf:"bytes,1,opt,name=secret_version,json=secretVersion,proto3" json:"secret_version,omitempty"`
	// The value of the secret
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

The secret response

func (*SecretAccessResponse) Descriptor deprecated

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

Deprecated: Use SecretAccessResponse.ProtoReflect.Descriptor instead.

func (*SecretAccessResponse) GetSecretVersion

func (x *SecretAccessResponse) GetSecretVersion() *SecretVersion

func (*SecretAccessResponse) GetValue

func (x *SecretAccessResponse) GetValue() []byte

func (*SecretAccessResponse) ProtoMessage

func (*SecretAccessResponse) ProtoMessage()

func (*SecretAccessResponse) ProtoReflect

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

func (*SecretAccessResponse) Reset

func (x *SecretAccessResponse) Reset()

func (*SecretAccessResponse) String

func (x *SecretAccessResponse) String() string

func (*SecretAccessResponse) Validate

func (m *SecretAccessResponse) Validate() error

Validate checks the field values on SecretAccessResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretAccessResponse) ValidateAll

func (m *SecretAccessResponse) ValidateAll() error

ValidateAll checks the field values on SecretAccessResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretAccessResponseMultiError, or nil if none found.

type SecretAccessResponseMultiError

type SecretAccessResponseMultiError []error

SecretAccessResponseMultiError is an error wrapping multiple validation errors returned by SecretAccessResponse.ValidateAll() if the designated constraints aren't met.

func (SecretAccessResponseMultiError) AllErrors

func (m SecretAccessResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretAccessResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SecretAccessResponseValidationError

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

SecretAccessResponseValidationError is the validation error returned by SecretAccessResponse.Validate if the designated constraints aren't met.

func (SecretAccessResponseValidationError) Cause

Cause function returns cause value.

func (SecretAccessResponseValidationError) Error

Error satisfies the builtin error interface

func (SecretAccessResponseValidationError) ErrorName

ErrorName returns error name.

func (SecretAccessResponseValidationError) Field

Field function returns field value.

func (SecretAccessResponseValidationError) Key

Key function returns key value.

func (SecretAccessResponseValidationError) Reason

Reason function returns reason value.

type SecretMultiError

type SecretMultiError []error

SecretMultiError is an error wrapping multiple validation errors returned by Secret.ValidateAll() if the designated constraints aren't met.

func (SecretMultiError) AllErrors

func (m SecretMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretMultiError) Error

func (m SecretMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SecretPutRequest

type SecretPutRequest struct {

	// The Secret to put to the Secret store
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The value to assign to that secret
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Request to put a secret to a Secret Store

func (*SecretPutRequest) Descriptor deprecated

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

Deprecated: Use SecretPutRequest.ProtoReflect.Descriptor instead.

func (*SecretPutRequest) GetSecret

func (x *SecretPutRequest) GetSecret() *Secret

func (*SecretPutRequest) GetValue

func (x *SecretPutRequest) GetValue() []byte

func (*SecretPutRequest) ProtoMessage

func (*SecretPutRequest) ProtoMessage()

func (*SecretPutRequest) ProtoReflect

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

func (*SecretPutRequest) Reset

func (x *SecretPutRequest) Reset()

func (*SecretPutRequest) String

func (x *SecretPutRequest) String() string

func (*SecretPutRequest) Validate

func (m *SecretPutRequest) Validate() error

Validate checks the field values on SecretPutRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretPutRequest) ValidateAll

func (m *SecretPutRequest) ValidateAll() error

ValidateAll checks the field values on SecretPutRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretPutRequestMultiError, or nil if none found.

type SecretPutRequestMultiError

type SecretPutRequestMultiError []error

SecretPutRequestMultiError is an error wrapping multiple validation errors returned by SecretPutRequest.ValidateAll() if the designated constraints aren't met.

func (SecretPutRequestMultiError) AllErrors

func (m SecretPutRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretPutRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SecretPutRequestValidationError

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

SecretPutRequestValidationError is the validation error returned by SecretPutRequest.Validate if the designated constraints aren't met.

func (SecretPutRequestValidationError) Cause

Cause function returns cause value.

func (SecretPutRequestValidationError) Error

Error satisfies the builtin error interface

func (SecretPutRequestValidationError) ErrorName

ErrorName returns error name.

func (SecretPutRequestValidationError) Field

Field function returns field value.

func (SecretPutRequestValidationError) Key

Key function returns key value.

func (SecretPutRequestValidationError) Reason

Reason function returns reason value.

type SecretPutResponse

type SecretPutResponse struct {

	// The id of the secret
	SecretVersion *SecretVersion `protobuf:"bytes,1,opt,name=secret_version,json=secretVersion,proto3" json:"secret_version,omitempty"`
	// contains filtered or unexported fields
}

Result from putting the secret to a Secret Store

func (*SecretPutResponse) Descriptor deprecated

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

Deprecated: Use SecretPutResponse.ProtoReflect.Descriptor instead.

func (*SecretPutResponse) GetSecretVersion

func (x *SecretPutResponse) GetSecretVersion() *SecretVersion

func (*SecretPutResponse) ProtoMessage

func (*SecretPutResponse) ProtoMessage()

func (*SecretPutResponse) ProtoReflect

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

func (*SecretPutResponse) Reset

func (x *SecretPutResponse) Reset()

func (*SecretPutResponse) String

func (x *SecretPutResponse) String() string

func (*SecretPutResponse) Validate

func (m *SecretPutResponse) Validate() error

Validate checks the field values on SecretPutResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretPutResponse) ValidateAll

func (m *SecretPutResponse) ValidateAll() error

ValidateAll checks the field values on SecretPutResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretPutResponseMultiError, or nil if none found.

type SecretPutResponseMultiError

type SecretPutResponseMultiError []error

SecretPutResponseMultiError is an error wrapping multiple validation errors returned by SecretPutResponse.ValidateAll() if the designated constraints aren't met.

func (SecretPutResponseMultiError) AllErrors

func (m SecretPutResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretPutResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SecretPutResponseValidationError

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

SecretPutResponseValidationError is the validation error returned by SecretPutResponse.Validate if the designated constraints aren't met.

func (SecretPutResponseValidationError) Cause

Cause function returns cause value.

func (SecretPutResponseValidationError) Error

Error satisfies the builtin error interface

func (SecretPutResponseValidationError) ErrorName

ErrorName returns error name.

func (SecretPutResponseValidationError) Field

Field function returns field value.

func (SecretPutResponseValidationError) Key

Key function returns key value.

func (SecretPutResponseValidationError) Reason

Reason function returns reason value.

type SecretResource added in v0.14.0

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

func (*SecretResource) Descriptor deprecated added in v0.14.0

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

Deprecated: Use SecretResource.ProtoReflect.Descriptor instead.

func (*SecretResource) ProtoMessage added in v0.14.0

func (*SecretResource) ProtoMessage()

func (*SecretResource) ProtoReflect added in v0.14.0

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

func (*SecretResource) Reset added in v0.14.0

func (x *SecretResource) Reset()

func (*SecretResource) String added in v0.14.0

func (x *SecretResource) String() string

func (*SecretResource) Validate added in v0.14.0

func (m *SecretResource) Validate() error

Validate checks the field values on SecretResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretResource) ValidateAll added in v0.14.0

func (m *SecretResource) ValidateAll() error

ValidateAll checks the field values on SecretResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretResourceMultiError, or nil if none found.

type SecretResourceMultiError added in v0.14.0

type SecretResourceMultiError []error

SecretResourceMultiError is an error wrapping multiple validation errors returned by SecretResource.ValidateAll() if the designated constraints aren't met.

func (SecretResourceMultiError) AllErrors added in v0.14.0

func (m SecretResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretResourceMultiError) Error added in v0.14.0

func (m SecretResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SecretResourceValidationError added in v0.14.0

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

SecretResourceValidationError is the validation error returned by SecretResource.Validate if the designated constraints aren't met.

func (SecretResourceValidationError) Cause added in v0.14.0

Cause function returns cause value.

func (SecretResourceValidationError) Error added in v0.14.0

Error satisfies the builtin error interface

func (SecretResourceValidationError) ErrorName added in v0.14.0

func (e SecretResourceValidationError) ErrorName() string

ErrorName returns error name.

func (SecretResourceValidationError) Field added in v0.14.0

Field function returns field value.

func (SecretResourceValidationError) Key added in v0.14.0

Key function returns key value.

func (SecretResourceValidationError) Reason added in v0.14.0

Reason function returns reason value.

type SecretServiceClient

type SecretServiceClient interface {
	// Updates a secret, creating a new one if it doesn't already exist
	Put(ctx context.Context, in *SecretPutRequest, opts ...grpc.CallOption) (*SecretPutResponse, error)
	// Gets a secret from a Secret Store
	Access(ctx context.Context, in *SecretAccessRequest, opts ...grpc.CallOption) (*SecretAccessResponse, error)
}

SecretServiceClient is the client API for SecretService 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.

type SecretServiceServer

type SecretServiceServer interface {
	// Updates a secret, creating a new one if it doesn't already exist
	Put(context.Context, *SecretPutRequest) (*SecretPutResponse, error)
	// Gets a secret from a Secret Store
	Access(context.Context, *SecretAccessRequest) (*SecretAccessResponse, error)
	// contains filtered or unexported methods
}

SecretServiceServer is the server API for SecretService service. All implementations must embed UnimplementedSecretServiceServer for forward compatibility

type SecretValidationError

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

SecretValidationError is the validation error returned by Secret.Validate if the designated constraints aren't met.

func (SecretValidationError) Cause

func (e SecretValidationError) Cause() error

Cause function returns cause value.

func (SecretValidationError) Error

func (e SecretValidationError) Error() string

Error satisfies the builtin error interface

func (SecretValidationError) ErrorName

func (e SecretValidationError) ErrorName() string

ErrorName returns error name.

func (SecretValidationError) Field

func (e SecretValidationError) Field() string

Field function returns field value.

func (SecretValidationError) Key

func (e SecretValidationError) Key() bool

Key function returns key value.

func (SecretValidationError) Reason

func (e SecretValidationError) Reason() string

Reason function returns reason value.

type SecretVersion

type SecretVersion struct {

	// Reference to the secret container
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The secret version
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` //map<string, string> labels = 4; //Tags for GCP and azure,
	// contains filtered or unexported fields
}

A version of a secret

func (*SecretVersion) Descriptor deprecated

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

Deprecated: Use SecretVersion.ProtoReflect.Descriptor instead.

func (*SecretVersion) GetSecret

func (x *SecretVersion) GetSecret() *Secret

func (*SecretVersion) GetVersion

func (x *SecretVersion) GetVersion() string

func (*SecretVersion) ProtoMessage

func (*SecretVersion) ProtoMessage()

func (*SecretVersion) ProtoReflect

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

func (*SecretVersion) Reset

func (x *SecretVersion) Reset()

func (*SecretVersion) String

func (x *SecretVersion) String() string

func (*SecretVersion) Validate

func (m *SecretVersion) Validate() error

Validate checks the field values on SecretVersion with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SecretVersion) ValidateAll

func (m *SecretVersion) ValidateAll() error

ValidateAll checks the field values on SecretVersion with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SecretVersionMultiError, or nil if none found.

type SecretVersionMultiError

type SecretVersionMultiError []error

SecretVersionMultiError is an error wrapping multiple validation errors returned by SecretVersion.ValidateAll() if the designated constraints aren't met.

func (SecretVersionMultiError) AllErrors

func (m SecretVersionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SecretVersionMultiError) Error

func (m SecretVersionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SecretVersionValidationError

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

SecretVersionValidationError is the validation error returned by SecretVersion.Validate if the designated constraints aren't met.

func (SecretVersionValidationError) Cause

Cause function returns cause value.

func (SecretVersionValidationError) Error

Error satisfies the builtin error interface

func (SecretVersionValidationError) ErrorName

func (e SecretVersionValidationError) ErrorName() string

ErrorName returns error name.

func (SecretVersionValidationError) Field

Field function returns field value.

func (SecretVersionValidationError) Key

Key function returns key value.

func (SecretVersionValidationError) Reason

Reason function returns reason value.

type ServerMessage

type ServerMessage struct {

	// Server message ID, used to pair requests/responses
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ServerMessage_InitResponse
	//	*ServerMessage_TriggerRequest
	Content isServerMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

Messages the server is able to send to the client

func (*ServerMessage) Descriptor deprecated

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

Deprecated: Use ServerMessage.ProtoReflect.Descriptor instead.

func (*ServerMessage) GetContent

func (m *ServerMessage) GetContent() isServerMessage_Content

func (*ServerMessage) GetId

func (x *ServerMessage) GetId() string

func (*ServerMessage) GetInitResponse

func (x *ServerMessage) GetInitResponse() *InitResponse

func (*ServerMessage) GetTriggerRequest

func (x *ServerMessage) GetTriggerRequest() *TriggerRequest

func (*ServerMessage) ProtoMessage

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) ProtoReflect

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

func (*ServerMessage) Reset

func (x *ServerMessage) Reset()

func (*ServerMessage) String

func (x *ServerMessage) String() string

func (*ServerMessage) Validate

func (m *ServerMessage) Validate() error

Validate checks the field values on ServerMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ServerMessage) ValidateAll

func (m *ServerMessage) ValidateAll() error

ValidateAll checks the field values on ServerMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServerMessageMultiError, or nil if none found.

type ServerMessageMultiError

type ServerMessageMultiError []error

ServerMessageMultiError is an error wrapping multiple validation errors returned by ServerMessage.ValidateAll() if the designated constraints aren't met.

func (ServerMessageMultiError) AllErrors

func (m ServerMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ServerMessageMultiError) Error

func (m ServerMessageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ServerMessageValidationError

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

ServerMessageValidationError is the validation error returned by ServerMessage.Validate if the designated constraints aren't met.

func (ServerMessageValidationError) Cause

Cause function returns cause value.

func (ServerMessageValidationError) Error

Error satisfies the builtin error interface

func (ServerMessageValidationError) ErrorName

func (e ServerMessageValidationError) ErrorName() string

ErrorName returns error name.

func (ServerMessageValidationError) Field

Field function returns field value.

func (ServerMessageValidationError) Key

Key function returns key value.

func (ServerMessageValidationError) Reason

Reason function returns reason value.

type ServerMessage_InitResponse

type ServerMessage_InitResponse struct {
	// Server responding
	// with client configuration details to an
	// InitRequest
	InitResponse *InitResponse `protobuf:"bytes,2,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type ServerMessage_TriggerRequest

type ServerMessage_TriggerRequest struct {
	// Server requesting client to
	// process a trigger
	TriggerRequest *TriggerRequest `protobuf:"bytes,3,opt,name=trigger_request,json=triggerRequest,proto3,oneof"`
}

type StorageDeleteRequest

type StorageDeleteRequest struct {

	// Name of the bucket to delete from
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to delete
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a storage item

func (*StorageDeleteRequest) Descriptor deprecated

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

Deprecated: Use StorageDeleteRequest.ProtoReflect.Descriptor instead.

func (*StorageDeleteRequest) GetBucketName

func (x *StorageDeleteRequest) GetBucketName() string

func (*StorageDeleteRequest) GetKey

func (x *StorageDeleteRequest) GetKey() string

func (*StorageDeleteRequest) ProtoMessage

func (*StorageDeleteRequest) ProtoMessage()

func (*StorageDeleteRequest) ProtoReflect

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

func (*StorageDeleteRequest) Reset

func (x *StorageDeleteRequest) Reset()

func (*StorageDeleteRequest) String

func (x *StorageDeleteRequest) String() string

func (*StorageDeleteRequest) Validate

func (m *StorageDeleteRequest) Validate() error

Validate checks the field values on StorageDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageDeleteRequest) ValidateAll

func (m *StorageDeleteRequest) ValidateAll() error

ValidateAll checks the field values on StorageDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageDeleteRequestMultiError, or nil if none found.

type StorageDeleteRequestMultiError

type StorageDeleteRequestMultiError []error

StorageDeleteRequestMultiError is an error wrapping multiple validation errors returned by StorageDeleteRequest.ValidateAll() if the designated constraints aren't met.

func (StorageDeleteRequestMultiError) AllErrors

func (m StorageDeleteRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageDeleteRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageDeleteRequestValidationError

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

StorageDeleteRequestValidationError is the validation error returned by StorageDeleteRequest.Validate if the designated constraints aren't met.

func (StorageDeleteRequestValidationError) Cause

Cause function returns cause value.

func (StorageDeleteRequestValidationError) Error

Error satisfies the builtin error interface

func (StorageDeleteRequestValidationError) ErrorName

ErrorName returns error name.

func (StorageDeleteRequestValidationError) Field

Field function returns field value.

func (StorageDeleteRequestValidationError) Key

Key function returns key value.

func (StorageDeleteRequestValidationError) Reason

Reason function returns reason value.

type StorageDeleteResponse

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

Result of deleting a storage item

func (*StorageDeleteResponse) Descriptor deprecated

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

Deprecated: Use StorageDeleteResponse.ProtoReflect.Descriptor instead.

func (*StorageDeleteResponse) ProtoMessage

func (*StorageDeleteResponse) ProtoMessage()

func (*StorageDeleteResponse) ProtoReflect

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

func (*StorageDeleteResponse) Reset

func (x *StorageDeleteResponse) Reset()

func (*StorageDeleteResponse) String

func (x *StorageDeleteResponse) String() string

func (*StorageDeleteResponse) Validate

func (m *StorageDeleteResponse) Validate() error

Validate checks the field values on StorageDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageDeleteResponse) ValidateAll

func (m *StorageDeleteResponse) ValidateAll() error

ValidateAll checks the field values on StorageDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageDeleteResponseMultiError, or nil if none found.

type StorageDeleteResponseMultiError

type StorageDeleteResponseMultiError []error

StorageDeleteResponseMultiError is an error wrapping multiple validation errors returned by StorageDeleteResponse.ValidateAll() if the designated constraints aren't met.

func (StorageDeleteResponseMultiError) AllErrors

func (m StorageDeleteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageDeleteResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageDeleteResponseValidationError

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

StorageDeleteResponseValidationError is the validation error returned by StorageDeleteResponse.Validate if the designated constraints aren't met.

func (StorageDeleteResponseValidationError) Cause

Cause function returns cause value.

func (StorageDeleteResponseValidationError) Error

Error satisfies the builtin error interface

func (StorageDeleteResponseValidationError) ErrorName

ErrorName returns error name.

func (StorageDeleteResponseValidationError) Field

Field function returns field value.

func (StorageDeleteResponseValidationError) Key

Key function returns key value.

func (StorageDeleteResponseValidationError) Reason

Reason function returns reason value.

type StorageListFilesRequest added in v0.16.0

type StorageListFilesRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageListFilesRequest) Descriptor deprecated added in v0.16.0

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

Deprecated: Use StorageListFilesRequest.ProtoReflect.Descriptor instead.

func (*StorageListFilesRequest) GetBucketName added in v0.16.0

func (x *StorageListFilesRequest) GetBucketName() string

func (*StorageListFilesRequest) ProtoMessage added in v0.16.0

func (*StorageListFilesRequest) ProtoMessage()

func (*StorageListFilesRequest) ProtoReflect added in v0.16.0

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

func (*StorageListFilesRequest) Reset added in v0.16.0

func (x *StorageListFilesRequest) Reset()

func (*StorageListFilesRequest) String added in v0.16.0

func (x *StorageListFilesRequest) String() string

func (*StorageListFilesRequest) Validate added in v0.16.0

func (m *StorageListFilesRequest) Validate() error

Validate checks the field values on StorageListFilesRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageListFilesRequest) ValidateAll added in v0.16.0

func (m *StorageListFilesRequest) ValidateAll() error

ValidateAll checks the field values on StorageListFilesRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageListFilesRequestMultiError, or nil if none found.

type StorageListFilesRequestMultiError added in v0.16.0

type StorageListFilesRequestMultiError []error

StorageListFilesRequestMultiError is an error wrapping multiple validation errors returned by StorageListFilesRequest.ValidateAll() if the designated constraints aren't met.

func (StorageListFilesRequestMultiError) AllErrors added in v0.16.0

func (m StorageListFilesRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageListFilesRequestMultiError) Error added in v0.16.0

Error returns a concatenation of all the error messages it wraps.

type StorageListFilesRequestValidationError added in v0.16.0

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

StorageListFilesRequestValidationError is the validation error returned by StorageListFilesRequest.Validate if the designated constraints aren't met.

func (StorageListFilesRequestValidationError) Cause added in v0.16.0

Cause function returns cause value.

func (StorageListFilesRequestValidationError) Error added in v0.16.0

Error satisfies the builtin error interface

func (StorageListFilesRequestValidationError) ErrorName added in v0.16.0

ErrorName returns error name.

func (StorageListFilesRequestValidationError) Field added in v0.16.0

Field function returns field value.

func (StorageListFilesRequestValidationError) Key added in v0.16.0

Key function returns key value.

func (StorageListFilesRequestValidationError) Reason added in v0.16.0

Reason function returns reason value.

type StorageListFilesResponse added in v0.16.0

type StorageListFilesResponse struct {

	// keys of the files in the bucket
	Files []*File `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageListFilesResponse) Descriptor deprecated added in v0.16.0

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

Deprecated: Use StorageListFilesResponse.ProtoReflect.Descriptor instead.

func (*StorageListFilesResponse) GetFiles added in v0.16.0

func (x *StorageListFilesResponse) GetFiles() []*File

func (*StorageListFilesResponse) ProtoMessage added in v0.16.0

func (*StorageListFilesResponse) ProtoMessage()

func (*StorageListFilesResponse) ProtoReflect added in v0.16.0

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

func (*StorageListFilesResponse) Reset added in v0.16.0

func (x *StorageListFilesResponse) Reset()

func (*StorageListFilesResponse) String added in v0.16.0

func (x *StorageListFilesResponse) String() string

func (*StorageListFilesResponse) Validate added in v0.16.0

func (m *StorageListFilesResponse) Validate() error

Validate checks the field values on StorageListFilesResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageListFilesResponse) ValidateAll added in v0.16.0

func (m *StorageListFilesResponse) ValidateAll() error

ValidateAll checks the field values on StorageListFilesResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageListFilesResponseMultiError, or nil if none found.

type StorageListFilesResponseMultiError added in v0.16.0

type StorageListFilesResponseMultiError []error

StorageListFilesResponseMultiError is an error wrapping multiple validation errors returned by StorageListFilesResponse.ValidateAll() if the designated constraints aren't met.

func (StorageListFilesResponseMultiError) AllErrors added in v0.16.0

func (m StorageListFilesResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageListFilesResponseMultiError) Error added in v0.16.0

Error returns a concatenation of all the error messages it wraps.

type StorageListFilesResponseValidationError added in v0.16.0

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

StorageListFilesResponseValidationError is the validation error returned by StorageListFilesResponse.Validate if the designated constraints aren't met.

func (StorageListFilesResponseValidationError) Cause added in v0.16.0

Cause function returns cause value.

func (StorageListFilesResponseValidationError) Error added in v0.16.0

Error satisfies the builtin error interface

func (StorageListFilesResponseValidationError) ErrorName added in v0.16.0

ErrorName returns error name.

func (StorageListFilesResponseValidationError) Field added in v0.16.0

Field function returns field value.

func (StorageListFilesResponseValidationError) Key added in v0.16.0

Key function returns key value.

func (StorageListFilesResponseValidationError) Reason added in v0.16.0

Reason function returns reason value.

type StoragePreSignUrlRequest

type StoragePreSignUrlRequest struct {

	// Nitric name of the bucket to retrieve from
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to generate the signed URL for.
	// The URL and the token it contains will only be valid for operations on this resource specifically.
	Key       string                             `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Operation StoragePreSignUrlRequest_Operation `` /* 130-byte string literal not displayed */
	// Expiry time in seconds for the token included in the signed URL.
	//
	//	Time starts from when the access token is generated, not when this request is made.
	//	e.g. time.Now().Add(expiry * time.Second) on the server
	Expiry uint32 `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

Request to generate a pre-signed URL for a file to perform a specific operation, such as read or write.

func (*StoragePreSignUrlRequest) Descriptor deprecated

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

Deprecated: Use StoragePreSignUrlRequest.ProtoReflect.Descriptor instead.

func (*StoragePreSignUrlRequest) GetBucketName

func (x *StoragePreSignUrlRequest) GetBucketName() string

func (*StoragePreSignUrlRequest) GetExpiry

func (x *StoragePreSignUrlRequest) GetExpiry() uint32

func (*StoragePreSignUrlRequest) GetKey

func (x *StoragePreSignUrlRequest) GetKey() string

func (*StoragePreSignUrlRequest) GetOperation

func (*StoragePreSignUrlRequest) ProtoMessage

func (*StoragePreSignUrlRequest) ProtoMessage()

func (*StoragePreSignUrlRequest) ProtoReflect

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

func (*StoragePreSignUrlRequest) Reset

func (x *StoragePreSignUrlRequest) Reset()

func (*StoragePreSignUrlRequest) String

func (x *StoragePreSignUrlRequest) String() string

func (*StoragePreSignUrlRequest) Validate

func (m *StoragePreSignUrlRequest) Validate() error

Validate checks the field values on StoragePreSignUrlRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StoragePreSignUrlRequest) ValidateAll

func (m *StoragePreSignUrlRequest) ValidateAll() error

ValidateAll checks the field values on StoragePreSignUrlRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StoragePreSignUrlRequestMultiError, or nil if none found.

type StoragePreSignUrlRequestMultiError

type StoragePreSignUrlRequestMultiError []error

StoragePreSignUrlRequestMultiError is an error wrapping multiple validation errors returned by StoragePreSignUrlRequest.ValidateAll() if the designated constraints aren't met.

func (StoragePreSignUrlRequestMultiError) AllErrors

func (m StoragePreSignUrlRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StoragePreSignUrlRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StoragePreSignUrlRequestValidationError

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

StoragePreSignUrlRequestValidationError is the validation error returned by StoragePreSignUrlRequest.Validate if the designated constraints aren't met.

func (StoragePreSignUrlRequestValidationError) Cause

Cause function returns cause value.

func (StoragePreSignUrlRequestValidationError) Error

Error satisfies the builtin error interface

func (StoragePreSignUrlRequestValidationError) ErrorName

ErrorName returns error name.

func (StoragePreSignUrlRequestValidationError) Field

Field function returns field value.

func (StoragePreSignUrlRequestValidationError) Key

Key function returns key value.

func (StoragePreSignUrlRequestValidationError) Reason

Reason function returns reason value.

type StoragePreSignUrlRequest_Operation

type StoragePreSignUrlRequest_Operation int32

Operation

const (
	StoragePreSignUrlRequest_READ  StoragePreSignUrlRequest_Operation = 0
	StoragePreSignUrlRequest_WRITE StoragePreSignUrlRequest_Operation = 1
)

func (StoragePreSignUrlRequest_Operation) Descriptor

func (StoragePreSignUrlRequest_Operation) Enum

func (StoragePreSignUrlRequest_Operation) EnumDescriptor deprecated

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

Deprecated: Use StoragePreSignUrlRequest_Operation.Descriptor instead.

func (StoragePreSignUrlRequest_Operation) Number

func (StoragePreSignUrlRequest_Operation) String

func (StoragePreSignUrlRequest_Operation) Type

type StoragePreSignUrlResponse

type StoragePreSignUrlResponse struct {

	// The pre-signed url, restricted to the operation, resource and expiry time specified in the request.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*StoragePreSignUrlResponse) Descriptor deprecated

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

Deprecated: Use StoragePreSignUrlResponse.ProtoReflect.Descriptor instead.

func (*StoragePreSignUrlResponse) GetUrl

func (x *StoragePreSignUrlResponse) GetUrl() string

func (*StoragePreSignUrlResponse) ProtoMessage

func (*StoragePreSignUrlResponse) ProtoMessage()

func (*StoragePreSignUrlResponse) ProtoReflect

func (*StoragePreSignUrlResponse) Reset

func (x *StoragePreSignUrlResponse) Reset()

func (*StoragePreSignUrlResponse) String

func (x *StoragePreSignUrlResponse) String() string

func (*StoragePreSignUrlResponse) Validate

func (m *StoragePreSignUrlResponse) Validate() error

Validate checks the field values on StoragePreSignUrlResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StoragePreSignUrlResponse) ValidateAll

func (m *StoragePreSignUrlResponse) ValidateAll() error

ValidateAll checks the field values on StoragePreSignUrlResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StoragePreSignUrlResponseMultiError, or nil if none found.

type StoragePreSignUrlResponseMultiError

type StoragePreSignUrlResponseMultiError []error

StoragePreSignUrlResponseMultiError is an error wrapping multiple validation errors returned by StoragePreSignUrlResponse.ValidateAll() if the designated constraints aren't met.

func (StoragePreSignUrlResponseMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (StoragePreSignUrlResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StoragePreSignUrlResponseValidationError

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

StoragePreSignUrlResponseValidationError is the validation error returned by StoragePreSignUrlResponse.Validate if the designated constraints aren't met.

func (StoragePreSignUrlResponseValidationError) Cause

Cause function returns cause value.

func (StoragePreSignUrlResponseValidationError) Error

Error satisfies the builtin error interface

func (StoragePreSignUrlResponseValidationError) ErrorName

ErrorName returns error name.

func (StoragePreSignUrlResponseValidationError) Field

Field function returns field value.

func (StoragePreSignUrlResponseValidationError) Key

Key function returns key value.

func (StoragePreSignUrlResponseValidationError) Reason

Reason function returns reason value.

type StorageReadRequest

type StorageReadRequest struct {

	// Nitric name of the bucket to retrieve from
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key of item to retrieve
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Request to retrieve a storage item

func (*StorageReadRequest) Descriptor deprecated

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

Deprecated: Use StorageReadRequest.ProtoReflect.Descriptor instead.

func (*StorageReadRequest) GetBucketName

func (x *StorageReadRequest) GetBucketName() string

func (*StorageReadRequest) GetKey

func (x *StorageReadRequest) GetKey() string

func (*StorageReadRequest) ProtoMessage

func (*StorageReadRequest) ProtoMessage()

func (*StorageReadRequest) ProtoReflect

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

func (*StorageReadRequest) Reset

func (x *StorageReadRequest) Reset()

func (*StorageReadRequest) String

func (x *StorageReadRequest) String() string

func (*StorageReadRequest) Validate

func (m *StorageReadRequest) Validate() error

Validate checks the field values on StorageReadRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageReadRequest) ValidateAll

func (m *StorageReadRequest) ValidateAll() error

ValidateAll checks the field values on StorageReadRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageReadRequestMultiError, or nil if none found.

type StorageReadRequestMultiError

type StorageReadRequestMultiError []error

StorageReadRequestMultiError is an error wrapping multiple validation errors returned by StorageReadRequest.ValidateAll() if the designated constraints aren't met.

func (StorageReadRequestMultiError) AllErrors

func (m StorageReadRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageReadRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageReadRequestValidationError

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

StorageReadRequestValidationError is the validation error returned by StorageReadRequest.Validate if the designated constraints aren't met.

func (StorageReadRequestValidationError) Cause

Cause function returns cause value.

func (StorageReadRequestValidationError) Error

Error satisfies the builtin error interface

func (StorageReadRequestValidationError) ErrorName

ErrorName returns error name.

func (StorageReadRequestValidationError) Field

Field function returns field value.

func (StorageReadRequestValidationError) Key

Key function returns key value.

func (StorageReadRequestValidationError) Reason

Reason function returns reason value.

type StorageReadResponse

type StorageReadResponse struct {

	// The body bytes of the retrieved storage item
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

Returned storage item

func (*StorageReadResponse) Descriptor deprecated

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

Deprecated: Use StorageReadResponse.ProtoReflect.Descriptor instead.

func (*StorageReadResponse) GetBody

func (x *StorageReadResponse) GetBody() []byte

func (*StorageReadResponse) ProtoMessage

func (*StorageReadResponse) ProtoMessage()

func (*StorageReadResponse) ProtoReflect

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

func (*StorageReadResponse) Reset

func (x *StorageReadResponse) Reset()

func (*StorageReadResponse) String

func (x *StorageReadResponse) String() string

func (*StorageReadResponse) Validate

func (m *StorageReadResponse) Validate() error

Validate checks the field values on StorageReadResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageReadResponse) ValidateAll

func (m *StorageReadResponse) ValidateAll() error

ValidateAll checks the field values on StorageReadResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageReadResponseMultiError, or nil if none found.

type StorageReadResponseMultiError

type StorageReadResponseMultiError []error

StorageReadResponseMultiError is an error wrapping multiple validation errors returned by StorageReadResponse.ValidateAll() if the designated constraints aren't met.

func (StorageReadResponseMultiError) AllErrors

func (m StorageReadResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageReadResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageReadResponseValidationError

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

StorageReadResponseValidationError is the validation error returned by StorageReadResponse.Validate if the designated constraints aren't met.

func (StorageReadResponseValidationError) Cause

Cause function returns cause value.

func (StorageReadResponseValidationError) Error

Error satisfies the builtin error interface

func (StorageReadResponseValidationError) ErrorName

ErrorName returns error name.

func (StorageReadResponseValidationError) Field

Field function returns field value.

func (StorageReadResponseValidationError) Key

Key function returns key value.

func (StorageReadResponseValidationError) Reason

Reason function returns reason value.

type StorageServiceClient

type StorageServiceClient interface {
	// Retrieve an item from a bucket
	Read(ctx context.Context, in *StorageReadRequest, opts ...grpc.CallOption) (*StorageReadResponse, error)
	// Store an item to a bucket
	Write(ctx context.Context, in *StorageWriteRequest, opts ...grpc.CallOption) (*StorageWriteResponse, error)
	// Delete an item from a bucket
	Delete(ctx context.Context, in *StorageDeleteRequest, opts ...grpc.CallOption) (*StorageDeleteResponse, error)
	// Generate a pre-signed URL for direct operations on an item
	PreSignUrl(ctx context.Context, in *StoragePreSignUrlRequest, opts ...grpc.CallOption) (*StoragePreSignUrlResponse, error)
	// List files currently in the bucket
	ListFiles(ctx context.Context, in *StorageListFilesRequest, opts ...grpc.CallOption) (*StorageListFilesResponse, error)
}

StorageServiceClient is the client API for StorageService 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.

type StorageServiceServer

type StorageServiceServer interface {
	// Retrieve an item from a bucket
	Read(context.Context, *StorageReadRequest) (*StorageReadResponse, error)
	// Store an item to a bucket
	Write(context.Context, *StorageWriteRequest) (*StorageWriteResponse, error)
	// Delete an item from a bucket
	Delete(context.Context, *StorageDeleteRequest) (*StorageDeleteResponse, error)
	// Generate a pre-signed URL for direct operations on an item
	PreSignUrl(context.Context, *StoragePreSignUrlRequest) (*StoragePreSignUrlResponse, error)
	// List files currently in the bucket
	ListFiles(context.Context, *StorageListFilesRequest) (*StorageListFilesResponse, error)
	// contains filtered or unexported methods
}

StorageServiceServer is the server API for StorageService service. All implementations must embed UnimplementedStorageServiceServer for forward compatibility

type StorageWriteRequest

type StorageWriteRequest struct {

	// Nitric name of the bucket to store in
	//
	//	this will be automatically resolved to the provider specific bucket identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Key to store the item under
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// bytes array to store
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

Request to put (create/update) a storage item

func (*StorageWriteRequest) Descriptor deprecated

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

Deprecated: Use StorageWriteRequest.ProtoReflect.Descriptor instead.

func (*StorageWriteRequest) GetBody

func (x *StorageWriteRequest) GetBody() []byte

func (*StorageWriteRequest) GetBucketName

func (x *StorageWriteRequest) GetBucketName() string

func (*StorageWriteRequest) GetKey

func (x *StorageWriteRequest) GetKey() string

func (*StorageWriteRequest) ProtoMessage

func (*StorageWriteRequest) ProtoMessage()

func (*StorageWriteRequest) ProtoReflect

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

func (*StorageWriteRequest) Reset

func (x *StorageWriteRequest) Reset()

func (*StorageWriteRequest) String

func (x *StorageWriteRequest) String() string

func (*StorageWriteRequest) Validate

func (m *StorageWriteRequest) Validate() error

Validate checks the field values on StorageWriteRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageWriteRequest) ValidateAll

func (m *StorageWriteRequest) ValidateAll() error

ValidateAll checks the field values on StorageWriteRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageWriteRequestMultiError, or nil if none found.

type StorageWriteRequestMultiError

type StorageWriteRequestMultiError []error

StorageWriteRequestMultiError is an error wrapping multiple validation errors returned by StorageWriteRequest.ValidateAll() if the designated constraints aren't met.

func (StorageWriteRequestMultiError) AllErrors

func (m StorageWriteRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageWriteRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageWriteRequestValidationError

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

StorageWriteRequestValidationError is the validation error returned by StorageWriteRequest.Validate if the designated constraints aren't met.

func (StorageWriteRequestValidationError) Cause

Cause function returns cause value.

func (StorageWriteRequestValidationError) Error

Error satisfies the builtin error interface

func (StorageWriteRequestValidationError) ErrorName

ErrorName returns error name.

func (StorageWriteRequestValidationError) Field

Field function returns field value.

func (StorageWriteRequestValidationError) Key

Key function returns key value.

func (StorageWriteRequestValidationError) Reason

Reason function returns reason value.

type StorageWriteResponse

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

Result of putting a storage item

func (*StorageWriteResponse) Descriptor deprecated

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

Deprecated: Use StorageWriteResponse.ProtoReflect.Descriptor instead.

func (*StorageWriteResponse) ProtoMessage

func (*StorageWriteResponse) ProtoMessage()

func (*StorageWriteResponse) ProtoReflect

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

func (*StorageWriteResponse) Reset

func (x *StorageWriteResponse) Reset()

func (*StorageWriteResponse) String

func (x *StorageWriteResponse) String() string

func (*StorageWriteResponse) Validate

func (m *StorageWriteResponse) Validate() error

Validate checks the field values on StorageWriteResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StorageWriteResponse) ValidateAll

func (m *StorageWriteResponse) ValidateAll() error

ValidateAll checks the field values on StorageWriteResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StorageWriteResponseMultiError, or nil if none found.

type StorageWriteResponseMultiError

type StorageWriteResponseMultiError []error

StorageWriteResponseMultiError is an error wrapping multiple validation errors returned by StorageWriteResponse.ValidateAll() if the designated constraints aren't met.

func (StorageWriteResponseMultiError) AllErrors

func (m StorageWriteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StorageWriteResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type StorageWriteResponseValidationError

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

StorageWriteResponseValidationError is the validation error returned by StorageWriteResponse.Validate if the designated constraints aren't met.

func (StorageWriteResponseValidationError) Cause

Cause function returns cause value.

func (StorageWriteResponseValidationError) Error

Error satisfies the builtin error interface

func (StorageWriteResponseValidationError) ErrorName

ErrorName returns error name.

func (StorageWriteResponseValidationError) Field

Field function returns field value.

func (StorageWriteResponseValidationError) Key

Key function returns key value.

func (StorageWriteResponseValidationError) Reason

Reason function returns reason value.

type SubscriptionWorker

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

func (*SubscriptionWorker) Descriptor deprecated

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

Deprecated: Use SubscriptionWorker.ProtoReflect.Descriptor instead.

func (*SubscriptionWorker) GetTopic

func (x *SubscriptionWorker) GetTopic() string

func (*SubscriptionWorker) ProtoMessage

func (*SubscriptionWorker) ProtoMessage()

func (*SubscriptionWorker) ProtoReflect

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

func (*SubscriptionWorker) Reset

func (x *SubscriptionWorker) Reset()

func (*SubscriptionWorker) String

func (x *SubscriptionWorker) String() string

func (*SubscriptionWorker) Validate

func (m *SubscriptionWorker) Validate() error

Validate checks the field values on SubscriptionWorker with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SubscriptionWorker) ValidateAll

func (m *SubscriptionWorker) ValidateAll() error

ValidateAll checks the field values on SubscriptionWorker with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SubscriptionWorkerMultiError, or nil if none found.

type SubscriptionWorkerMultiError

type SubscriptionWorkerMultiError []error

SubscriptionWorkerMultiError is an error wrapping multiple validation errors returned by SubscriptionWorker.ValidateAll() if the designated constraints aren't met.

func (SubscriptionWorkerMultiError) AllErrors

func (m SubscriptionWorkerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SubscriptionWorkerMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SubscriptionWorkerValidationError

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

SubscriptionWorkerValidationError is the validation error returned by SubscriptionWorker.Validate if the designated constraints aren't met.

func (SubscriptionWorkerValidationError) Cause

Cause function returns cause value.

func (SubscriptionWorkerValidationError) Error

Error satisfies the builtin error interface

func (SubscriptionWorkerValidationError) ErrorName

ErrorName returns error name.

func (SubscriptionWorkerValidationError) Field

Field function returns field value.

func (SubscriptionWorkerValidationError) Key

Key function returns key value.

func (SubscriptionWorkerValidationError) Reason

Reason function returns reason value.

type TopicListRequest

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

Request for the Topic List method

func (*TopicListRequest) Descriptor deprecated

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

Deprecated: Use TopicListRequest.ProtoReflect.Descriptor instead.

func (*TopicListRequest) ProtoMessage

func (*TopicListRequest) ProtoMessage()

func (*TopicListRequest) ProtoReflect

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

func (*TopicListRequest) Reset

func (x *TopicListRequest) Reset()

func (*TopicListRequest) String

func (x *TopicListRequest) String() string

func (*TopicListRequest) Validate

func (m *TopicListRequest) Validate() error

Validate checks the field values on TopicListRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicListRequest) ValidateAll

func (m *TopicListRequest) ValidateAll() error

ValidateAll checks the field values on TopicListRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicListRequestMultiError, or nil if none found.

type TopicListRequestMultiError

type TopicListRequestMultiError []error

TopicListRequestMultiError is an error wrapping multiple validation errors returned by TopicListRequest.ValidateAll() if the designated constraints aren't met.

func (TopicListRequestMultiError) AllErrors

func (m TopicListRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicListRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TopicListRequestValidationError

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

TopicListRequestValidationError is the validation error returned by TopicListRequest.Validate if the designated constraints aren't met.

func (TopicListRequestValidationError) Cause

Cause function returns cause value.

func (TopicListRequestValidationError) Error

Error satisfies the builtin error interface

func (TopicListRequestValidationError) ErrorName

ErrorName returns error name.

func (TopicListRequestValidationError) Field

Field function returns field value.

func (TopicListRequestValidationError) Key

Key function returns key value.

func (TopicListRequestValidationError) Reason

Reason function returns reason value.

type TopicListResponse

type TopicListResponse struct {

	// The list of found topics
	Topics []*NitricTopic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

Topic List Response

func (*TopicListResponse) Descriptor deprecated

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

Deprecated: Use TopicListResponse.ProtoReflect.Descriptor instead.

func (*TopicListResponse) GetTopics

func (x *TopicListResponse) GetTopics() []*NitricTopic

func (*TopicListResponse) ProtoMessage

func (*TopicListResponse) ProtoMessage()

func (*TopicListResponse) ProtoReflect

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

func (*TopicListResponse) Reset

func (x *TopicListResponse) Reset()

func (*TopicListResponse) String

func (x *TopicListResponse) String() string

func (*TopicListResponse) Validate

func (m *TopicListResponse) Validate() error

Validate checks the field values on TopicListResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicListResponse) ValidateAll

func (m *TopicListResponse) ValidateAll() error

ValidateAll checks the field values on TopicListResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicListResponseMultiError, or nil if none found.

type TopicListResponseMultiError

type TopicListResponseMultiError []error

TopicListResponseMultiError is an error wrapping multiple validation errors returned by TopicListResponse.ValidateAll() if the designated constraints aren't met.

func (TopicListResponseMultiError) AllErrors

func (m TopicListResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicListResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TopicListResponseValidationError

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

TopicListResponseValidationError is the validation error returned by TopicListResponse.Validate if the designated constraints aren't met.

func (TopicListResponseValidationError) Cause

Cause function returns cause value.

func (TopicListResponseValidationError) Error

Error satisfies the builtin error interface

func (TopicListResponseValidationError) ErrorName

ErrorName returns error name.

func (TopicListResponseValidationError) Field

Field function returns field value.

func (TopicListResponseValidationError) Key

Key function returns key value.

func (TopicListResponseValidationError) Reason

Reason function returns reason value.

type TopicResource

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

func (*TopicResource) Descriptor deprecated

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

Deprecated: Use TopicResource.ProtoReflect.Descriptor instead.

func (*TopicResource) ProtoMessage

func (*TopicResource) ProtoMessage()

func (*TopicResource) ProtoReflect

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

func (*TopicResource) Reset

func (x *TopicResource) Reset()

func (*TopicResource) String

func (x *TopicResource) String() string

func (*TopicResource) Validate

func (m *TopicResource) Validate() error

Validate checks the field values on TopicResource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicResource) ValidateAll

func (m *TopicResource) ValidateAll() error

ValidateAll checks the field values on TopicResource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicResourceMultiError, or nil if none found.

type TopicResourceMultiError

type TopicResourceMultiError []error

TopicResourceMultiError is an error wrapping multiple validation errors returned by TopicResource.ValidateAll() if the designated constraints aren't met.

func (TopicResourceMultiError) AllErrors

func (m TopicResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicResourceMultiError) Error

func (m TopicResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TopicResourceValidationError

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

TopicResourceValidationError is the validation error returned by TopicResource.Validate if the designated constraints aren't met.

func (TopicResourceValidationError) Cause

Cause function returns cause value.

func (TopicResourceValidationError) Error

Error satisfies the builtin error interface

func (TopicResourceValidationError) ErrorName

func (e TopicResourceValidationError) ErrorName() string

ErrorName returns error name.

func (TopicResourceValidationError) Field

Field function returns field value.

func (TopicResourceValidationError) Key

Key function returns key value.

func (TopicResourceValidationError) Reason

Reason function returns reason value.

type TopicResponseContext

type TopicResponseContext struct {

	// Success status of the handled event
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

Specific event response message We do not accept responses for events only whether or not they were successfully processed

func (*TopicResponseContext) Descriptor deprecated

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

Deprecated: Use TopicResponseContext.ProtoReflect.Descriptor instead.

func (*TopicResponseContext) GetSuccess

func (x *TopicResponseContext) GetSuccess() bool

func (*TopicResponseContext) ProtoMessage

func (*TopicResponseContext) ProtoMessage()

func (*TopicResponseContext) ProtoReflect

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

func (*TopicResponseContext) Reset

func (x *TopicResponseContext) Reset()

func (*TopicResponseContext) String

func (x *TopicResponseContext) String() string

func (*TopicResponseContext) Validate

func (m *TopicResponseContext) Validate() error

Validate checks the field values on TopicResponseContext with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicResponseContext) ValidateAll

func (m *TopicResponseContext) ValidateAll() error

ValidateAll checks the field values on TopicResponseContext with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicResponseContextMultiError, or nil if none found.

type TopicResponseContextMultiError

type TopicResponseContextMultiError []error

TopicResponseContextMultiError is an error wrapping multiple validation errors returned by TopicResponseContext.ValidateAll() if the designated constraints aren't met.

func (TopicResponseContextMultiError) AllErrors

func (m TopicResponseContextMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicResponseContextMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TopicResponseContextValidationError

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

TopicResponseContextValidationError is the validation error returned by TopicResponseContext.Validate if the designated constraints aren't met.

func (TopicResponseContextValidationError) Cause

Cause function returns cause value.

func (TopicResponseContextValidationError) Error

Error satisfies the builtin error interface

func (TopicResponseContextValidationError) ErrorName

ErrorName returns error name.

func (TopicResponseContextValidationError) Field

Field function returns field value.

func (TopicResponseContextValidationError) Key

Key function returns key value.

func (TopicResponseContextValidationError) Reason

Reason function returns reason value.

type TopicServiceClient

type TopicServiceClient interface {
	// Return a list of existing topics in the provider environment
	List(ctx context.Context, in *TopicListRequest, opts ...grpc.CallOption) (*TopicListResponse, error)
}

TopicServiceClient is the client API for TopicService 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.

type TopicServiceServer

type TopicServiceServer interface {
	// Return a list of existing topics in the provider environment
	List(context.Context, *TopicListRequest) (*TopicListResponse, error)
	// contains filtered or unexported methods
}

TopicServiceServer is the server API for TopicService service. All implementations must embed UnimplementedTopicServiceServer for forward compatibility

type TopicTriggerContext

type TopicTriggerContext struct {

	// The topic the message was published for
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicTriggerContext) Descriptor deprecated

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

Deprecated: Use TopicTriggerContext.ProtoReflect.Descriptor instead.

func (*TopicTriggerContext) GetTopic

func (x *TopicTriggerContext) GetTopic() string

func (*TopicTriggerContext) ProtoMessage

func (*TopicTriggerContext) ProtoMessage()

func (*TopicTriggerContext) ProtoReflect

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

func (*TopicTriggerContext) Reset

func (x *TopicTriggerContext) Reset()

func (*TopicTriggerContext) String

func (x *TopicTriggerContext) String() string

func (*TopicTriggerContext) Validate

func (m *TopicTriggerContext) Validate() error

Validate checks the field values on TopicTriggerContext with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicTriggerContext) ValidateAll

func (m *TopicTriggerContext) ValidateAll() error

ValidateAll checks the field values on TopicTriggerContext with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicTriggerContextMultiError, or nil if none found.

type TopicTriggerContextMultiError

type TopicTriggerContextMultiError []error

TopicTriggerContextMultiError is an error wrapping multiple validation errors returned by TopicTriggerContext.ValidateAll() if the designated constraints aren't met.

func (TopicTriggerContextMultiError) AllErrors

func (m TopicTriggerContextMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicTriggerContextMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TopicTriggerContextValidationError

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

TopicTriggerContextValidationError is the validation error returned by TopicTriggerContext.Validate if the designated constraints aren't met.

func (TopicTriggerContextValidationError) Cause

Cause function returns cause value.

func (TopicTriggerContextValidationError) Error

Error satisfies the builtin error interface

func (TopicTriggerContextValidationError) ErrorName

ErrorName returns error name.

func (TopicTriggerContextValidationError) Field

Field function returns field value.

func (TopicTriggerContextValidationError) Key

Key function returns key value.

func (TopicTriggerContextValidationError) Reason

Reason function returns reason value.

type TraceContext added in v0.21.0

type TraceContext struct {
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TraceContext) Descriptor deprecated added in v0.21.0

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetValues added in v0.21.0

func (x *TraceContext) GetValues() map[string]string

func (*TraceContext) ProtoMessage added in v0.21.0

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect added in v0.21.0

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

func (*TraceContext) Reset added in v0.21.0

func (x *TraceContext) Reset()

func (*TraceContext) String added in v0.21.0

func (x *TraceContext) String() string

func (*TraceContext) Validate added in v0.21.0

func (m *TraceContext) Validate() error

Validate checks the field values on TraceContext with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TraceContext) ValidateAll added in v0.21.0

func (m *TraceContext) ValidateAll() error

ValidateAll checks the field values on TraceContext with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TraceContextMultiError, or nil if none found.

type TraceContextMultiError added in v0.21.0

type TraceContextMultiError []error

TraceContextMultiError is an error wrapping multiple validation errors returned by TraceContext.ValidateAll() if the designated constraints aren't met.

func (TraceContextMultiError) AllErrors added in v0.21.0

func (m TraceContextMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TraceContextMultiError) Error added in v0.21.0

func (m TraceContextMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TraceContextValidationError added in v0.21.0

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

TraceContextValidationError is the validation error returned by TraceContext.Validate if the designated constraints aren't met.

func (TraceContextValidationError) Cause added in v0.21.0

Cause function returns cause value.

func (TraceContextValidationError) Error added in v0.21.0

Error satisfies the builtin error interface

func (TraceContextValidationError) ErrorName added in v0.21.0

func (e TraceContextValidationError) ErrorName() string

ErrorName returns error name.

func (TraceContextValidationError) Field added in v0.21.0

Field function returns field value.

func (TraceContextValidationError) Key added in v0.21.0

Key function returns key value.

func (TraceContextValidationError) Reason added in v0.21.0

Reason function returns reason value.

type TriggerRequest

type TriggerRequest struct {

	// The data in the trigger
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Should we supply a mime type for the data?
	// Or rely on context?
	MimeType string `protobuf:"bytes,2,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	// TraceInformation from the membrane
	// Allows tying traces from external triggers (e.g. HttpRequests)
	// into each event request/response pair of the Bidirectional stream.
	// which cannot be facilitated by OOTB stream interceptors from OTEL.
	TraceContext *TraceContext `protobuf:"bytes,10,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
	// The context of the trigger
	//
	// Types that are assignable to Context:
	//
	//	*TriggerRequest_Http
	//	*TriggerRequest_Topic
	Context isTriggerRequest_Context `protobuf_oneof:"context"`
	// contains filtered or unexported fields
}

The server has a trigger for the client to handle

func (*TriggerRequest) Descriptor deprecated

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

Deprecated: Use TriggerRequest.ProtoReflect.Descriptor instead.

func (*TriggerRequest) GetContext

func (m *TriggerRequest) GetContext() isTriggerRequest_Context

func (*TriggerRequest) GetData

func (x *TriggerRequest) GetData() []byte

func (*TriggerRequest) GetHttp

func (x *TriggerRequest) GetHttp() *HttpTriggerContext

func (*TriggerRequest) GetMimeType

func (x *TriggerRequest) GetMimeType() string

func (*TriggerRequest) GetTopic

func (x *TriggerRequest) GetTopic() *TopicTriggerContext

func (*TriggerRequest) GetTraceContext added in v0.21.0

func (x *TriggerRequest) GetTraceContext() *TraceContext

func (*TriggerRequest) ProtoMessage

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) ProtoReflect

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

func (*TriggerRequest) Reset

func (x *TriggerRequest) Reset()

func (*TriggerRequest) String

func (x *TriggerRequest) String() string

func (*TriggerRequest) Validate

func (m *TriggerRequest) Validate() error

Validate checks the field values on TriggerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TriggerRequest) ValidateAll

func (m *TriggerRequest) ValidateAll() error

ValidateAll checks the field values on TriggerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TriggerRequestMultiError, or nil if none found.

type TriggerRequestMultiError

type TriggerRequestMultiError []error

TriggerRequestMultiError is an error wrapping multiple validation errors returned by TriggerRequest.ValidateAll() if the designated constraints aren't met.

func (TriggerRequestMultiError) AllErrors

func (m TriggerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerRequestMultiError) Error

func (m TriggerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TriggerRequestValidationError

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

TriggerRequestValidationError is the validation error returned by TriggerRequest.Validate if the designated constraints aren't met.

func (TriggerRequestValidationError) Cause

Cause function returns cause value.

func (TriggerRequestValidationError) Error

Error satisfies the builtin error interface

func (TriggerRequestValidationError) ErrorName

func (e TriggerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (TriggerRequestValidationError) Field

Field function returns field value.

func (TriggerRequestValidationError) Key

Key function returns key value.

func (TriggerRequestValidationError) Reason

Reason function returns reason value.

type TriggerRequest_Http

type TriggerRequest_Http struct {
	Http *HttpTriggerContext `protobuf:"bytes,3,opt,name=http,proto3,oneof"`
}

type TriggerRequest_Topic

type TriggerRequest_Topic struct {
	Topic *TopicTriggerContext `protobuf:"bytes,4,opt,name=topic,proto3,oneof"`
}

type TriggerResponse

type TriggerResponse struct {

	// The data returned in the response
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The context of the request response
	// Typically this will be one to one with the Trigger Context
	// i.e. if you receive http context you may return http context
	//
	// Types that are assignable to Context:
	//
	//	*TriggerResponse_Http
	//	*TriggerResponse_Topic
	Context isTriggerResponse_Context `protobuf_oneof:"context"`
	// contains filtered or unexported fields
}

The worker has successfully processed a trigger

func (*TriggerResponse) Descriptor deprecated

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

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) GetContext

func (m *TriggerResponse) GetContext() isTriggerResponse_Context

func (*TriggerResponse) GetData

func (x *TriggerResponse) GetData() []byte

func (*TriggerResponse) GetHttp

func (x *TriggerResponse) GetHttp() *HttpResponseContext

func (*TriggerResponse) GetTopic

func (x *TriggerResponse) GetTopic() *TopicResponseContext

func (*TriggerResponse) ProtoMessage

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect

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

func (*TriggerResponse) Reset

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String

func (x *TriggerResponse) String() string

func (*TriggerResponse) Validate

func (m *TriggerResponse) Validate() error

Validate checks the field values on TriggerResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TriggerResponse) ValidateAll

func (m *TriggerResponse) ValidateAll() error

ValidateAll checks the field values on TriggerResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TriggerResponseMultiError, or nil if none found.

type TriggerResponseMultiError

type TriggerResponseMultiError []error

TriggerResponseMultiError is an error wrapping multiple validation errors returned by TriggerResponse.ValidateAll() if the designated constraints aren't met.

func (TriggerResponseMultiError) AllErrors

func (m TriggerResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TriggerResponseValidationError

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

TriggerResponseValidationError is the validation error returned by TriggerResponse.Validate if the designated constraints aren't met.

func (TriggerResponseValidationError) Cause

Cause function returns cause value.

func (TriggerResponseValidationError) Error

Error satisfies the builtin error interface

func (TriggerResponseValidationError) ErrorName

func (e TriggerResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TriggerResponseValidationError) Field

Field function returns field value.

func (TriggerResponseValidationError) Key

Key function returns key value.

func (TriggerResponseValidationError) Reason

Reason function returns reason value.

type TriggerResponse_Http

type TriggerResponse_Http struct {
	// response to a http request
	Http *HttpResponseContext `protobuf:"bytes,10,opt,name=http,proto3,oneof"`
}

type TriggerResponse_Topic

type TriggerResponse_Topic struct {
	// response to a topic trigger
	Topic *TopicResponseContext `protobuf:"bytes,11,opt,name=topic,proto3,oneof"`
}

type UnimplementedDocumentServiceServer

type UnimplementedDocumentServiceServer struct {
}

UnimplementedDocumentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDocumentServiceServer) Delete

func (UnimplementedDocumentServiceServer) Get

func (UnimplementedDocumentServiceServer) Query

func (UnimplementedDocumentServiceServer) Set

type UnimplementedEventServiceServer

type UnimplementedEventServiceServer struct {
}

UnimplementedEventServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEventServiceServer) Publish

type UnimplementedFaasServiceServer

type UnimplementedFaasServiceServer struct {
}

UnimplementedFaasServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFaasServiceServer) TriggerStream

type UnimplementedQueueServiceServer

type UnimplementedQueueServiceServer struct {
}

UnimplementedQueueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedQueueServiceServer) Complete

func (UnimplementedQueueServiceServer) Receive

func (UnimplementedQueueServiceServer) Send

func (UnimplementedQueueServiceServer) SendBatch

type UnimplementedResourceServiceServer

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Declare

func (UnimplementedResourceServiceServer) Details added in v0.20.0

type UnimplementedSecretServiceServer

type UnimplementedSecretServiceServer struct {
}

UnimplementedSecretServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSecretServiceServer) Access

func (UnimplementedSecretServiceServer) Put

type UnimplementedStorageServiceServer

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStorageServiceServer) Delete

func (UnimplementedStorageServiceServer) ListFiles added in v0.16.0

func (UnimplementedStorageServiceServer) Read

func (UnimplementedStorageServiceServer) Write

type UnimplementedTopicServiceServer

type UnimplementedTopicServiceServer struct {
}

UnimplementedTopicServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTopicServiceServer) List

type UnsafeDocumentServiceServer

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

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

type UnsafeEventServiceServer

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

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

type UnsafeFaasServiceServer

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

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

type UnsafeQueueServiceServer

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

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

type UnsafeResourceServiceServer

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

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

type UnsafeSecretServiceServer

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

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

type UnsafeStorageServiceServer

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

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

type UnsafeTopicServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL