v1

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 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 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,
		},
	},
	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 added in v0.4.0 

func RegisterDocumentServiceServer(s grpc.ServiceRegistrar, srv DocumentServiceServer)

func RegisterEventServiceServer added in v0.4.0 

func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

func RegisterFaasServiceServer added in v0.4.0 

func RegisterFaasServiceServer(s grpc.ServiceRegistrar, srv FaasServiceServer)

func RegisterQueueServiceServer added in v0.4.0 

func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)

func RegisterSecretServiceServer added in v0.5.0 

func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

func RegisterStorageServiceServer added in v0.4.0 

func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)

func RegisterTopicServiceServer added in v0.4.0 

func RegisterTopicServiceServer(s grpc.ServiceRegistrar, srv TopicServiceServer)

Types

type ClientMessage added in v0.3.0 

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 valid to be assigned to Content:
	//	*ClientMessage_InitRequest
	//	*ClientMessage_TriggerResponse
	Content              isClientMessage_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Messages the client is able to send to the server

func (*ClientMessage) Descriptor added in v0.3.0 

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

func (*ClientMessage) GetContent added in v0.3.0 

func (m *ClientMessage) GetContent() isClientMessage_Content

func (*ClientMessage) GetId added in v0.3.0 

func (m *ClientMessage) GetId() string

func (*ClientMessage) GetInitRequest added in v0.3.0 

func (m *ClientMessage) GetInitRequest() *InitRequest

func (*ClientMessage) GetTriggerResponse added in v0.3.0 

func (m *ClientMessage) GetTriggerResponse() *TriggerResponse

func (*ClientMessage) ProtoMessage added in v0.3.0 

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) Reset added in v0.3.0 

func (m *ClientMessage) Reset()

func (*ClientMessage) String added in v0.3.0 

func (m *ClientMessage) String() string

func (*ClientMessage) XXX_DiscardUnknown added in v0.7.2 

func (m *ClientMessage) XXX_DiscardUnknown()

func (*ClientMessage) XXX_Marshal added in v0.7.2 

func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientMessage) XXX_Merge added in v0.7.2 

func (m *ClientMessage) XXX_Merge(src proto.Message)

func (*ClientMessage) XXX_OneofWrappers added in v0.7.2 

func (*ClientMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientMessage) XXX_Size added in v0.7.2 

func (m *ClientMessage) XXX_Size() int

func (*ClientMessage) XXX_Unmarshal added in v0.7.2 

func (m *ClientMessage) XXX_Unmarshal(b []byte) error

type ClientMessage_InitRequest added in v0.3.0 

type ClientMessage_InitRequest struct {
	InitRequest *InitRequest `protobuf:"bytes,2,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type ClientMessage_TriggerResponse added in v0.3.0 

type ClientMessage_TriggerResponse struct {
	TriggerResponse *TriggerResponse `protobuf:"bytes,3,opt,name=trigger_response,json=triggerResponse,proto3,oneof"`
}

type Collection added in v0.4.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Provides a Collection type for storing documents

func (*Collection) Descriptor added in v0.4.0 

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

func (*Collection) GetName added in v0.4.0 

func (m *Collection) GetName() string

func (*Collection) GetParent added in v0.4.0 

func (m *Collection) GetParent() *Key

func (*Collection) ProtoMessage added in v0.4.0 

func (*Collection) ProtoMessage()

func (*Collection) Reset added in v0.4.0 

func (m *Collection) Reset()

func (*Collection) String added in v0.4.0 

func (m *Collection) String() string

func (*Collection) XXX_DiscardUnknown added in v0.7.2 

func (m *Collection) XXX_DiscardUnknown()

func (*Collection) XXX_Marshal added in v0.7.2 

func (m *Collection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Collection) XXX_Merge added in v0.7.2 

func (m *Collection) XXX_Merge(src proto.Message)

func (*Collection) XXX_Size added in v0.7.2 

func (m *Collection) XXX_Size() int

func (*Collection) XXX_Unmarshal added in v0.7.2 

func (m *Collection) XXX_Unmarshal(b []byte) error

type Document added in v0.4.0 

type Document struct {
	// The document content (JSON object)
	Content *_struct.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Provides a return document type

func (*Document) Descriptor added in v0.4.0 

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

func (*Document) GetContent added in v0.4.0 

func (m *Document) GetContent() *_struct.Struct

func (*Document) GetKey added in v0.4.0 

func (m *Document) GetKey() *Key

func (*Document) ProtoMessage added in v0.4.0 

func (*Document) ProtoMessage()

func (*Document) Reset added in v0.4.0 

func (m *Document) Reset()

func (*Document) String added in v0.4.0 

func (m *Document) String() string

func (*Document) XXX_DiscardUnknown added in v0.7.2 

func (m *Document) XXX_DiscardUnknown()

func (*Document) XXX_Marshal added in v0.7.2 

func (m *Document) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Document) XXX_Merge added in v0.7.2 

func (m *Document) XXX_Merge(src proto.Message)

func (*Document) XXX_Size added in v0.7.2 

func (m *Document) XXX_Size() int

func (*Document) XXX_Unmarshal added in v0.7.2 

func (m *Document) XXX_Unmarshal(b []byte) error

type DocumentDeleteRequest added in v0.4.0 

type DocumentDeleteRequest struct {
	// Key of the document to delete
	Key                  *Key     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocumentDeleteRequest) Descriptor added in v0.4.0 

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

func (*DocumentDeleteRequest) GetKey added in v0.4.0 

func (m *DocumentDeleteRequest) GetKey() *Key

func (*DocumentDeleteRequest) ProtoMessage added in v0.4.0 

func (*DocumentDeleteRequest) ProtoMessage()

func (*DocumentDeleteRequest) Reset added in v0.4.0 

func (m *DocumentDeleteRequest) Reset()

func (*DocumentDeleteRequest) String added in v0.4.0 

func (m *DocumentDeleteRequest) String() string

func (*DocumentDeleteRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentDeleteRequest) XXX_DiscardUnknown()

func (*DocumentDeleteRequest) XXX_Marshal added in v0.7.2 

func (m *DocumentDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentDeleteRequest) XXX_Merge added in v0.7.2 

func (m *DocumentDeleteRequest) XXX_Merge(src proto.Message)

func (*DocumentDeleteRequest) XXX_Size added in v0.7.2 

func (m *DocumentDeleteRequest) XXX_Size() int

func (*DocumentDeleteRequest) XXX_Unmarshal added in v0.7.2 

func (m *DocumentDeleteRequest) XXX_Unmarshal(b []byte) error

type DocumentDeleteResponse added in v0.4.0 

type DocumentDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocumentDeleteResponse) Descriptor added in v0.4.0 

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

func (*DocumentDeleteResponse) ProtoMessage added in v0.4.0 

func (*DocumentDeleteResponse) ProtoMessage()

func (*DocumentDeleteResponse) Reset added in v0.4.0 

func (m *DocumentDeleteResponse) Reset()

func (*DocumentDeleteResponse) String added in v0.4.0 

func (m *DocumentDeleteResponse) String() string

func (*DocumentDeleteResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentDeleteResponse) XXX_DiscardUnknown()

func (*DocumentDeleteResponse) XXX_Marshal added in v0.7.2 

func (m *DocumentDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentDeleteResponse) XXX_Merge added in v0.7.2 

func (m *DocumentDeleteResponse) XXX_Merge(src proto.Message)

func (*DocumentDeleteResponse) XXX_Size added in v0.7.2 

func (m *DocumentDeleteResponse) XXX_Size() int

func (*DocumentDeleteResponse) XXX_Unmarshal added in v0.7.2 

func (m *DocumentDeleteResponse) XXX_Unmarshal(b []byte) error

type DocumentGetRequest added in v0.4.0 

type DocumentGetRequest struct {
	// Key of the document to retrieve
	Key                  *Key     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocumentGetRequest) Descriptor added in v0.4.0 

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

func (*DocumentGetRequest) GetKey added in v0.4.0 

func (m *DocumentGetRequest) GetKey() *Key

func (*DocumentGetRequest) ProtoMessage added in v0.4.0 

func (*DocumentGetRequest) ProtoMessage()

func (*DocumentGetRequest) Reset added in v0.4.0 

func (m *DocumentGetRequest) Reset()

func (*DocumentGetRequest) String added in v0.4.0 

func (m *DocumentGetRequest) String() string

func (*DocumentGetRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentGetRequest) XXX_DiscardUnknown()

func (*DocumentGetRequest) XXX_Marshal added in v0.7.2 

func (m *DocumentGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentGetRequest) XXX_Merge added in v0.7.2 

func (m *DocumentGetRequest) XXX_Merge(src proto.Message)

func (*DocumentGetRequest) XXX_Size added in v0.7.2 

func (m *DocumentGetRequest) XXX_Size() int

func (*DocumentGetRequest) XXX_Unmarshal added in v0.7.2 

func (m *DocumentGetRequest) XXX_Unmarshal(b []byte) error

type DocumentGetResponse added in v0.4.0 

type DocumentGetResponse struct {
	// The retrieved value
	Document             *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DocumentGetResponse) Descriptor added in v0.4.0 

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

func (*DocumentGetResponse) GetDocument added in v0.4.0 

func (m *DocumentGetResponse) GetDocument() *Document

func (*DocumentGetResponse) ProtoMessage added in v0.4.0 

func (*DocumentGetResponse) ProtoMessage()

func (*DocumentGetResponse) Reset added in v0.4.0 

func (m *DocumentGetResponse) Reset()

func (*DocumentGetResponse) String added in v0.4.0 

func (m *DocumentGetResponse) String() string

func (*DocumentGetResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentGetResponse) XXX_DiscardUnknown()

func (*DocumentGetResponse) XXX_Marshal added in v0.7.2 

func (m *DocumentGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentGetResponse) XXX_Merge added in v0.7.2 

func (m *DocumentGetResponse) XXX_Merge(src proto.Message)

func (*DocumentGetResponse) XXX_Size added in v0.7.2 

func (m *DocumentGetResponse) XXX_Size() int

func (*DocumentGetResponse) XXX_Unmarshal added in v0.7.2 

func (m *DocumentGetResponse) XXX_Unmarshal(b []byte) error

type DocumentQueryRequest added in v0.4.0 

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DocumentQueryRequest) Descriptor added in v0.4.0 

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

func (*DocumentQueryRequest) GetCollection added in v0.4.0 

func (m *DocumentQueryRequest) GetCollection() *Collection

func (*DocumentQueryRequest) GetExpressions added in v0.4.0 

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

func (*DocumentQueryRequest) GetLimit added in v0.4.0 

func (m *DocumentQueryRequest) GetLimit() int32

func (*DocumentQueryRequest) GetPagingToken added in v0.4.0 

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

func (*DocumentQueryRequest) ProtoMessage added in v0.4.0 

func (*DocumentQueryRequest) ProtoMessage()

func (*DocumentQueryRequest) Reset added in v0.4.0 

func (m *DocumentQueryRequest) Reset()

func (*DocumentQueryRequest) String added in v0.4.0 

func (m *DocumentQueryRequest) String() string

func (*DocumentQueryRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentQueryRequest) XXX_DiscardUnknown()

func (*DocumentQueryRequest) XXX_Marshal added in v0.7.2 

func (m *DocumentQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentQueryRequest) XXX_Merge added in v0.7.2 

func (m *DocumentQueryRequest) XXX_Merge(src proto.Message)

func (*DocumentQueryRequest) XXX_Size added in v0.7.2 

func (m *DocumentQueryRequest) XXX_Size() int

func (*DocumentQueryRequest) XXX_Unmarshal added in v0.7.2 

func (m *DocumentQueryRequest) XXX_Unmarshal(b []byte) error

type DocumentQueryResponse added in v0.4.0 

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DocumentQueryResponse) Descriptor added in v0.4.0 

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

func (*DocumentQueryResponse) GetDocuments added in v0.4.0 

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

func (*DocumentQueryResponse) GetPagingToken added in v0.4.0 

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

func (*DocumentQueryResponse) ProtoMessage added in v0.4.0 

func (*DocumentQueryResponse) ProtoMessage()

func (*DocumentQueryResponse) Reset added in v0.4.0 

func (m *DocumentQueryResponse) Reset()

func (*DocumentQueryResponse) String added in v0.4.0 

func (m *DocumentQueryResponse) String() string

func (*DocumentQueryResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentQueryResponse) XXX_DiscardUnknown()

func (*DocumentQueryResponse) XXX_Marshal added in v0.7.2 

func (m *DocumentQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentQueryResponse) XXX_Merge added in v0.7.2 

func (m *DocumentQueryResponse) XXX_Merge(src proto.Message)

func (*DocumentQueryResponse) XXX_Size added in v0.7.2 

func (m *DocumentQueryResponse) XXX_Size() int

func (*DocumentQueryResponse) XXX_Unmarshal added in v0.7.2 

func (m *DocumentQueryResponse) XXX_Unmarshal(b []byte) error

type DocumentQueryStreamRequest added in v0.4.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocumentQueryStreamRequest) Descriptor added in v0.4.0 

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

func (*DocumentQueryStreamRequest) GetCollection added in v0.4.0 

func (m *DocumentQueryStreamRequest) GetCollection() *Collection

func (*DocumentQueryStreamRequest) GetExpressions added in v0.4.0 

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

func (*DocumentQueryStreamRequest) GetLimit added in v0.4.0 

func (m *DocumentQueryStreamRequest) GetLimit() int32

func (*DocumentQueryStreamRequest) ProtoMessage added in v0.4.0 

func (*DocumentQueryStreamRequest) ProtoMessage()

func (*DocumentQueryStreamRequest) Reset added in v0.4.0 

func (m *DocumentQueryStreamRequest) Reset()

func (*DocumentQueryStreamRequest) String added in v0.4.0 

func (m *DocumentQueryStreamRequest) String() string

func (*DocumentQueryStreamRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentQueryStreamRequest) XXX_DiscardUnknown()

func (*DocumentQueryStreamRequest) XXX_Marshal added in v0.7.2 

func (m *DocumentQueryStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentQueryStreamRequest) XXX_Merge added in v0.7.2 

func (m *DocumentQueryStreamRequest) XXX_Merge(src proto.Message)

func (*DocumentQueryStreamRequest) XXX_Size added in v0.7.2 

func (m *DocumentQueryStreamRequest) XXX_Size() int

func (*DocumentQueryStreamRequest) XXX_Unmarshal added in v0.7.2 

func (m *DocumentQueryStreamRequest) XXX_Unmarshal(b []byte) error

type DocumentQueryStreamResponse added in v0.4.0 

type DocumentQueryStreamResponse struct {
	// The stream document
	Document             *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DocumentQueryStreamResponse) Descriptor added in v0.4.0 

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

func (*DocumentQueryStreamResponse) GetDocument added in v0.4.0 

func (m *DocumentQueryStreamResponse) GetDocument() *Document

func (*DocumentQueryStreamResponse) ProtoMessage added in v0.4.0 

func (*DocumentQueryStreamResponse) ProtoMessage()

func (*DocumentQueryStreamResponse) Reset added in v0.4.0 

func (m *DocumentQueryStreamResponse) Reset()

func (*DocumentQueryStreamResponse) String added in v0.4.0 

func (m *DocumentQueryStreamResponse) String() string

func (*DocumentQueryStreamResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentQueryStreamResponse) XXX_DiscardUnknown()

func (*DocumentQueryStreamResponse) XXX_Marshal added in v0.7.2 

func (m *DocumentQueryStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentQueryStreamResponse) XXX_Merge added in v0.7.2 

func (m *DocumentQueryStreamResponse) XXX_Merge(src proto.Message)

func (*DocumentQueryStreamResponse) XXX_Size added in v0.7.2 

func (m *DocumentQueryStreamResponse) XXX_Size() int

func (*DocumentQueryStreamResponse) XXX_Unmarshal added in v0.7.2 

func (m *DocumentQueryStreamResponse) XXX_Unmarshal(b []byte) error

type DocumentServiceClient added in v0.4.0 

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.

func NewDocumentServiceClient added in v0.4.0 

func NewDocumentServiceClient(cc grpc.ClientConnInterface) DocumentServiceClient

type DocumentServiceServer added in v0.4.0 

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
}

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

type DocumentService_QueryStreamClient added in v0.4.0 

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

type DocumentService_QueryStreamServer added in v0.4.0 

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

type DocumentSetRequest added in v0.4.0 

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              *_struct.Struct `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DocumentSetRequest) Descriptor added in v0.4.0 

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

func (*DocumentSetRequest) GetContent added in v0.4.0 

func (m *DocumentSetRequest) GetContent() *_struct.Struct

func (*DocumentSetRequest) GetKey added in v0.4.0 

func (m *DocumentSetRequest) GetKey() *Key

func (*DocumentSetRequest) ProtoMessage added in v0.4.0 

func (*DocumentSetRequest) ProtoMessage()

func (*DocumentSetRequest) Reset added in v0.4.0 

func (m *DocumentSetRequest) Reset()

func (*DocumentSetRequest) String added in v0.4.0 

func (m *DocumentSetRequest) String() string

func (*DocumentSetRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentSetRequest) XXX_DiscardUnknown()

func (*DocumentSetRequest) XXX_Marshal added in v0.7.2 

func (m *DocumentSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentSetRequest) XXX_Merge added in v0.7.2 

func (m *DocumentSetRequest) XXX_Merge(src proto.Message)

func (*DocumentSetRequest) XXX_Size added in v0.7.2 

func (m *DocumentSetRequest) XXX_Size() int

func (*DocumentSetRequest) XXX_Unmarshal added in v0.7.2 

func (m *DocumentSetRequest) XXX_Unmarshal(b []byte) error

type DocumentSetResponse added in v0.4.0 

type DocumentSetResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocumentSetResponse) Descriptor added in v0.4.0 

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

func (*DocumentSetResponse) ProtoMessage added in v0.4.0 

func (*DocumentSetResponse) ProtoMessage()

func (*DocumentSetResponse) Reset added in v0.4.0 

func (m *DocumentSetResponse) Reset()

func (*DocumentSetResponse) String added in v0.4.0 

func (m *DocumentSetResponse) String() string

func (*DocumentSetResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *DocumentSetResponse) XXX_DiscardUnknown()

func (*DocumentSetResponse) XXX_Marshal added in v0.7.2 

func (m *DocumentSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocumentSetResponse) XXX_Merge added in v0.7.2 

func (m *DocumentSetResponse) XXX_Merge(src proto.Message)

func (*DocumentSetResponse) XXX_Size added in v0.7.2 

func (m *DocumentSetResponse) XXX_Size() int

func (*DocumentSetResponse) XXX_Unmarshal added in v0.7.2 

func (m *DocumentSetResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Request to publish an event to a topic

func (*EventPublishRequest) Descriptor 

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

func (*EventPublishRequest) GetEvent 

func (m *EventPublishRequest) GetEvent() *NitricEvent

func (*EventPublishRequest) GetTopic 

func (m *EventPublishRequest) GetTopic() string

func (*EventPublishRequest) ProtoMessage 

func (*EventPublishRequest) ProtoMessage()

func (*EventPublishRequest) Reset 

func (m *EventPublishRequest) Reset()

func (*EventPublishRequest) String 

func (m *EventPublishRequest) String() string

func (*EventPublishRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *EventPublishRequest) XXX_DiscardUnknown()

func (*EventPublishRequest) XXX_Marshal added in v0.7.2 

func (m *EventPublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventPublishRequest) XXX_Merge added in v0.7.2 

func (m *EventPublishRequest) XXX_Merge(src proto.Message)

func (*EventPublishRequest) XXX_Size added in v0.7.2 

func (m *EventPublishRequest) XXX_Size() int

func (*EventPublishRequest) XXX_Unmarshal added in v0.7.2 

func (m *EventPublishRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Result of publishing an event

func (*EventPublishResponse) Descriptor 

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

func (*EventPublishResponse) GetId 

func (m *EventPublishResponse) GetId() string

func (*EventPublishResponse) ProtoMessage 

func (*EventPublishResponse) ProtoMessage()

func (*EventPublishResponse) Reset 

func (m *EventPublishResponse) Reset()

func (*EventPublishResponse) String 

func (m *EventPublishResponse) String() string

func (*EventPublishResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *EventPublishResponse) XXX_DiscardUnknown()

func (*EventPublishResponse) XXX_Marshal added in v0.7.2 

func (m *EventPublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventPublishResponse) XXX_Merge added in v0.7.2 

func (m *EventPublishResponse) XXX_Merge(src proto.Message)

func (*EventPublishResponse) XXX_Size added in v0.7.2 

func (m *EventPublishResponse) XXX_Size() int

func (*EventPublishResponse) XXX_Unmarshal added in v0.7.2 

func (m *EventPublishResponse) XXX_Unmarshal(b []byte) error

type EventServiceClient added in v0.4.0 

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.

func NewEventServiceClient added in v0.4.0 

func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

type EventServiceServer added in v0.4.0 

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

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

type Expression added in v0.4.0 

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Provides a query expression type

func (*Expression) Descriptor added in v0.4.0 

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

func (*Expression) GetOperand added in v0.4.0 

func (m *Expression) GetOperand() string

func (*Expression) GetOperator added in v0.4.0 

func (m *Expression) GetOperator() string

func (*Expression) GetValue added in v0.4.0 

func (m *Expression) GetValue() *ExpressionValue

func (*Expression) ProtoMessage added in v0.4.0 

func (*Expression) ProtoMessage()

func (*Expression) Reset added in v0.4.0 

func (m *Expression) Reset()

func (*Expression) String added in v0.4.0 

func (m *Expression) String() string

func (*Expression) XXX_DiscardUnknown added in v0.7.2 

func (m *Expression) XXX_DiscardUnknown()

func (*Expression) XXX_Marshal added in v0.7.2 

func (m *Expression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Expression) XXX_Merge added in v0.7.2 

func (m *Expression) XXX_Merge(src proto.Message)

func (*Expression) XXX_Size added in v0.7.2 

func (m *Expression) XXX_Size() int

func (*Expression) XXX_Unmarshal added in v0.7.2 

func (m *Expression) XXX_Unmarshal(b []byte) error

type ExpressionValue added in v0.4.0 

type ExpressionValue struct {
	// The kind of value.
	//
	// Types that are valid to be assigned to Kind:
	//	*ExpressionValue_IntValue
	//	*ExpressionValue_DoubleValue
	//	*ExpressionValue_StringValue
	//	*ExpressionValue_BoolValue
	Kind                 isExpressionValue_Kind `protobuf_oneof:"kind"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ExpressionValue) Descriptor added in v0.4.0 

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

func (*ExpressionValue) GetBoolValue added in v0.4.0 

func (m *ExpressionValue) GetBoolValue() bool

func (*ExpressionValue) GetDoubleValue added in v0.4.0 

func (m *ExpressionValue) GetDoubleValue() float64

func (*ExpressionValue) GetIntValue added in v0.4.0 

func (m *ExpressionValue) GetIntValue() int64

func (*ExpressionValue) GetKind added in v0.4.0 

func (m *ExpressionValue) GetKind() isExpressionValue_Kind

func (*ExpressionValue) GetStringValue added in v0.4.0 

func (m *ExpressionValue) GetStringValue() string

func (*ExpressionValue) ProtoMessage added in v0.4.0 

func (*ExpressionValue) ProtoMessage()

func (*ExpressionValue) Reset added in v0.4.0 

func (m *ExpressionValue) Reset()

func (*ExpressionValue) String added in v0.4.0 

func (m *ExpressionValue) String() string

func (*ExpressionValue) XXX_DiscardUnknown added in v0.7.2 

func (m *ExpressionValue) XXX_DiscardUnknown()

func (*ExpressionValue) XXX_Marshal added in v0.7.2 

func (m *ExpressionValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExpressionValue) XXX_Merge added in v0.7.2 

func (m *ExpressionValue) XXX_Merge(src proto.Message)

func (*ExpressionValue) XXX_OneofWrappers added in v0.7.2 

func (*ExpressionValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExpressionValue) XXX_Size added in v0.7.2 

func (m *ExpressionValue) XXX_Size() int

func (*ExpressionValue) XXX_Unmarshal added in v0.7.2 

func (m *ExpressionValue) XXX_Unmarshal(b []byte) error

type ExpressionValue_BoolValue added in v0.4.0 

type ExpressionValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type ExpressionValue_DoubleValue added in v0.4.0 

type ExpressionValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type ExpressionValue_IntValue added in v0.4.0 

type ExpressionValue_IntValue struct {
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ExpressionValue_StringValue added in v0.4.0 

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

type FaasServiceClient added in v0.4.0 

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.

func NewFaasServiceClient added in v0.4.0 

func NewFaasServiceClient(cc grpc.ClientConnInterface) FaasServiceClient

type FaasServiceServer added in v0.4.0 

type FaasServiceServer interface {
	// Begin streaming triggers/response to/from the membrane
	TriggerStream(FaasService_TriggerStreamServer) error
}

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

type FaasService_TriggerStreamClient added in v0.4.0 

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

type FaasService_TriggerStreamServer added in v0.4.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FailedTask) Descriptor 

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

func (*FailedTask) GetMessage 

func (m *FailedTask) GetMessage() string

func (*FailedTask) GetTask 

func (m *FailedTask) GetTask() *NitricTask

func (*FailedTask) ProtoMessage 

func (*FailedTask) ProtoMessage()

func (*FailedTask) Reset 

func (m *FailedTask) Reset()

func (*FailedTask) String 

func (m *FailedTask) String() string

func (*FailedTask) XXX_DiscardUnknown added in v0.7.2 

func (m *FailedTask) XXX_DiscardUnknown()

func (*FailedTask) XXX_Marshal added in v0.7.2 

func (m *FailedTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FailedTask) XXX_Merge added in v0.7.2 

func (m *FailedTask) XXX_Merge(src proto.Message)

func (*FailedTask) XXX_Size added in v0.7.2 

func (m *FailedTask) XXX_Size() int

func (*FailedTask) XXX_Unmarshal added in v0.7.2 

func (m *FailedTask) XXX_Unmarshal(b []byte) error

type HeaderValue added in v0.7.2 

type HeaderValue struct {
	Value                []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeaderValue) Descriptor added in v0.7.2 

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

func (*HeaderValue) GetValue added in v0.7.2 

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

func (*HeaderValue) ProtoMessage added in v0.7.2 

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) Reset added in v0.7.2 

func (m *HeaderValue) Reset()

func (*HeaderValue) String added in v0.7.2 

func (m *HeaderValue) String() string

func (*HeaderValue) XXX_DiscardUnknown added in v0.7.2 

func (m *HeaderValue) XXX_DiscardUnknown()

func (*HeaderValue) XXX_Marshal added in v0.7.2 

func (m *HeaderValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeaderValue) XXX_Merge added in v0.7.2 

func (m *HeaderValue) XXX_Merge(src proto.Message)

func (*HeaderValue) XXX_Size added in v0.7.2 

func (m *HeaderValue) XXX_Size() int

func (*HeaderValue) XXX_Unmarshal added in v0.7.2 

func (m *HeaderValue) XXX_Unmarshal(b []byte) error

type HttpResponseContext added in v0.3.0 

type HttpResponseContext struct {
	// Old HTTP response headers (deprecated)
	// TODO: Remove in 1.0
	HeadersOld map[string]string `` // Deprecated: Do not use.
	/* 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 */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 added in v0.3.0 

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

func (*HttpResponseContext) GetHeaders added in v0.3.0 

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

func (*HttpResponseContext) GetHeadersOld deprecated added in v0.7.2 

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

Deprecated: Do not use.

func (*HttpResponseContext) GetStatus added in v0.3.0 

func (m *HttpResponseContext) GetStatus() int32

func (*HttpResponseContext) ProtoMessage added in v0.3.0 

func (*HttpResponseContext) ProtoMessage()

func (*HttpResponseContext) Reset added in v0.3.0 

func (m *HttpResponseContext) Reset()

func (*HttpResponseContext) String added in v0.3.0 

func (m *HttpResponseContext) String() string

func (*HttpResponseContext) XXX_DiscardUnknown added in v0.7.2 

func (m *HttpResponseContext) XXX_DiscardUnknown()

func (*HttpResponseContext) XXX_Marshal added in v0.7.2 

func (m *HttpResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpResponseContext) XXX_Merge added in v0.7.2 

func (m *HttpResponseContext) XXX_Merge(src proto.Message)

func (*HttpResponseContext) XXX_Size added in v0.7.2 

func (m *HttpResponseContext) XXX_Size() int

func (*HttpResponseContext) XXX_Unmarshal added in v0.7.2 

func (m *HttpResponseContext) XXX_Unmarshal(b []byte) error

type HttpTriggerContext added in v0.3.0 

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
	HeadersOld map[string]string `` // Deprecated: Do not use.
	/* 179-byte string literal not displayed */
	// The query params (if parseable by the membrane)
	QueryParams map[string]string `` /* 182-byte string literal not displayed */
	// HTTP request headers
	Headers              map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*HttpTriggerContext) Descriptor added in v0.3.0 

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

func (*HttpTriggerContext) GetHeaders added in v0.3.0 

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

func (*HttpTriggerContext) GetHeadersOld deprecated added in v0.7.2 

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

Deprecated: Do not use.

func (*HttpTriggerContext) GetMethod added in v0.3.0 

func (m *HttpTriggerContext) GetMethod() string

func (*HttpTriggerContext) GetPath added in v0.3.0 

func (m *HttpTriggerContext) GetPath() string

func (*HttpTriggerContext) GetQueryParams added in v0.3.0 

func (m *HttpTriggerContext) GetQueryParams() map[string]string

func (*HttpTriggerContext) ProtoMessage added in v0.3.0 

func (*HttpTriggerContext) ProtoMessage()

func (*HttpTriggerContext) Reset added in v0.3.0 

func (m *HttpTriggerContext) Reset()

func (*HttpTriggerContext) String added in v0.3.0 

func (m *HttpTriggerContext) String() string

func (*HttpTriggerContext) XXX_DiscardUnknown added in v0.7.2 

func (m *HttpTriggerContext) XXX_DiscardUnknown()

func (*HttpTriggerContext) XXX_Marshal added in v0.7.2 

func (m *HttpTriggerContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpTriggerContext) XXX_Merge added in v0.7.2 

func (m *HttpTriggerContext) XXX_Merge(src proto.Message)

func (*HttpTriggerContext) XXX_Size added in v0.7.2 

func (m *HttpTriggerContext) XXX_Size() int

func (*HttpTriggerContext) XXX_Unmarshal added in v0.7.2 

func (m *HttpTriggerContext) XXX_Unmarshal(b []byte) error

type InitRequest added in v0.3.0 

type InitRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Placeholder message

func (*InitRequest) Descriptor added in v0.3.0 

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

func (*InitRequest) ProtoMessage added in v0.3.0 

func (*InitRequest) ProtoMessage()

func (*InitRequest) Reset added in v0.3.0 

func (m *InitRequest) Reset()

func (*InitRequest) String added in v0.3.0 

func (m *InitRequest) String() string

func (*InitRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *InitRequest) XXX_DiscardUnknown()

func (*InitRequest) XXX_Marshal added in v0.7.2 

func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitRequest) XXX_Merge added in v0.7.2 

func (m *InitRequest) XXX_Merge(src proto.Message)

func (*InitRequest) XXX_Size added in v0.7.2 

func (m *InitRequest) XXX_Size() int

func (*InitRequest) XXX_Unmarshal added in v0.7.2 

func (m *InitRequest) XXX_Unmarshal(b []byte) error

type InitResponse added in v0.3.0 

type InitResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Placeholder message

func (*InitResponse) Descriptor added in v0.3.0 

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

func (*InitResponse) ProtoMessage added in v0.3.0 

func (*InitResponse) ProtoMessage()

func (*InitResponse) Reset added in v0.3.0 

func (m *InitResponse) Reset()

func (*InitResponse) String added in v0.3.0 

func (m *InitResponse) String() string

func (*InitResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *InitResponse) XXX_DiscardUnknown()

func (*InitResponse) XXX_Marshal added in v0.7.2 

func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitResponse) XXX_Merge added in v0.7.2 

func (m *InitResponse) XXX_Merge(src proto.Message)

func (*InitResponse) XXX_Size added in v0.7.2 

func (m *InitResponse) XXX_Size() int

func (*InitResponse) XXX_Unmarshal added in v0.7.2 

func (m *InitResponse) XXX_Unmarshal(b []byte) error

type Key added in v0.4.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Provides a document identifying key type

func (*Key) Descriptor added in v0.4.0 

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

func (*Key) GetCollection added in v0.4.0 

func (m *Key) GetCollection() *Collection

func (*Key) GetId added in v0.4.0 

func (m *Key) GetId() string

func (*Key) ProtoMessage added in v0.4.0 

func (*Key) ProtoMessage()

func (*Key) Reset added in v0.4.0 

func (m *Key) Reset()

func (*Key) String added in v0.4.0 

func (m *Key) String() string

func (*Key) XXX_DiscardUnknown added in v0.7.2 

func (m *Key) XXX_DiscardUnknown()

func (*Key) XXX_Marshal added in v0.7.2 

func (m *Key) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Key) XXX_Merge added in v0.7.2 

func (m *Key) XXX_Merge(src proto.Message)

func (*Key) XXX_Size added in v0.7.2 

func (m *Key) XXX_Size() int

func (*Key) XXX_Unmarshal added in v0.7.2 

func (m *Key) XXX_Unmarshal(b []byte) error

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              *_struct.Struct `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Nitric Event Model

func (*NitricEvent) Descriptor 

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

func (*NitricEvent) GetId 

func (m *NitricEvent) GetId() string

func (*NitricEvent) GetPayload 

func (m *NitricEvent) GetPayload() *_struct.Struct

func (*NitricEvent) GetPayloadType 

func (m *NitricEvent) GetPayloadType() string

func (*NitricEvent) ProtoMessage 

func (*NitricEvent) ProtoMessage()

func (*NitricEvent) Reset 

func (m *NitricEvent) Reset()

func (*NitricEvent) String 

func (m *NitricEvent) String() string

func (*NitricEvent) XXX_DiscardUnknown added in v0.7.2 

func (m *NitricEvent) XXX_DiscardUnknown()

func (*NitricEvent) XXX_Marshal added in v0.7.2 

func (m *NitricEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NitricEvent) XXX_Merge added in v0.7.2 

func (m *NitricEvent) XXX_Merge(src proto.Message)

func (*NitricEvent) XXX_Size added in v0.7.2 

func (m *NitricEvent) XXX_Size() int

func (*NitricEvent) XXX_Unmarshal added in v0.7.2 

func (m *NitricEvent) XXX_Unmarshal(b []byte) error

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              *_struct.Struct `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A task to be sent or received from a queue.

func (*NitricTask) Descriptor 

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

func (*NitricTask) GetId 

func (m *NitricTask) GetId() string

func (*NitricTask) GetLeaseId 

func (m *NitricTask) GetLeaseId() string

func (*NitricTask) GetPayload 

func (m *NitricTask) GetPayload() *_struct.Struct

func (*NitricTask) GetPayloadType 

func (m *NitricTask) GetPayloadType() string

func (*NitricTask) ProtoMessage 

func (*NitricTask) ProtoMessage()

func (*NitricTask) Reset 

func (m *NitricTask) Reset()

func (*NitricTask) String 

func (m *NitricTask) String() string

func (*NitricTask) XXX_DiscardUnknown added in v0.7.2 

func (m *NitricTask) XXX_DiscardUnknown()

func (*NitricTask) XXX_Marshal added in v0.7.2 

func (m *NitricTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NitricTask) XXX_Merge added in v0.7.2 

func (m *NitricTask) XXX_Merge(src proto.Message)

func (*NitricTask) XXX_Size added in v0.7.2 

func (m *NitricTask) XXX_Size() int

func (*NitricTask) XXX_Unmarshal added in v0.7.2 

func (m *NitricTask) XXX_Unmarshal(b []byte) error

type NitricTopic 

type NitricTopic struct {
	// The Nitric name for the topic
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents an event topic

func (*NitricTopic) Descriptor 

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

func (*NitricTopic) GetName 

func (m *NitricTopic) GetName() string

func (*NitricTopic) ProtoMessage 

func (*NitricTopic) ProtoMessage()

func (*NitricTopic) Reset 

func (m *NitricTopic) Reset()

func (*NitricTopic) String 

func (m *NitricTopic) String() string

func (*NitricTopic) XXX_DiscardUnknown added in v0.7.2 

func (m *NitricTopic) XXX_DiscardUnknown()

func (*NitricTopic) XXX_Marshal added in v0.7.2 

func (m *NitricTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NitricTopic) XXX_Merge added in v0.7.2 

func (m *NitricTopic) XXX_Merge(src proto.Message)

func (*NitricTopic) XXX_Size added in v0.7.2 

func (m *NitricTopic) XXX_Size() int

func (*NitricTopic) XXX_Unmarshal added in v0.7.2 

func (m *NitricTopic) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueueCompleteRequest) Descriptor 

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

func (*QueueCompleteRequest) GetLeaseId 

func (m *QueueCompleteRequest) GetLeaseId() string

func (*QueueCompleteRequest) GetQueue 

func (m *QueueCompleteRequest) GetQueue() string

func (*QueueCompleteRequest) ProtoMessage 

func (*QueueCompleteRequest) ProtoMessage()

func (*QueueCompleteRequest) Reset 

func (m *QueueCompleteRequest) Reset()

func (*QueueCompleteRequest) String 

func (m *QueueCompleteRequest) String() string

func (*QueueCompleteRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueCompleteRequest) XXX_DiscardUnknown()

func (*QueueCompleteRequest) XXX_Marshal added in v0.7.2 

func (m *QueueCompleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueCompleteRequest) XXX_Merge added in v0.7.2 

func (m *QueueCompleteRequest) XXX_Merge(src proto.Message)

func (*QueueCompleteRequest) XXX_Size added in v0.7.2 

func (m *QueueCompleteRequest) XXX_Size() int

func (*QueueCompleteRequest) XXX_Unmarshal added in v0.7.2 

func (m *QueueCompleteRequest) XXX_Unmarshal(b []byte) error

type QueueCompleteResponse 

type QueueCompleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueueCompleteResponse) Descriptor 

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

func (*QueueCompleteResponse) ProtoMessage 

func (*QueueCompleteResponse) ProtoMessage()

func (*QueueCompleteResponse) Reset 

func (m *QueueCompleteResponse) Reset()

func (*QueueCompleteResponse) String 

func (m *QueueCompleteResponse) String() string

func (*QueueCompleteResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueCompleteResponse) XXX_DiscardUnknown()

func (*QueueCompleteResponse) XXX_Marshal added in v0.7.2 

func (m *QueueCompleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueCompleteResponse) XXX_Merge added in v0.7.2 

func (m *QueueCompleteResponse) XXX_Merge(src proto.Message)

func (*QueueCompleteResponse) XXX_Size added in v0.7.2 

func (m *QueueCompleteResponse) XXX_Size() int

func (*QueueCompleteResponse) XXX_Unmarshal added in v0.7.2 

func (m *QueueCompleteResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueueReceiveRequest) Descriptor 

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

func (*QueueReceiveRequest) GetDepth 

func (m *QueueReceiveRequest) GetDepth() int32

func (*QueueReceiveRequest) GetQueue 

func (m *QueueReceiveRequest) GetQueue() string

func (*QueueReceiveRequest) ProtoMessage 

func (*QueueReceiveRequest) ProtoMessage()

func (*QueueReceiveRequest) Reset 

func (m *QueueReceiveRequest) Reset()

func (*QueueReceiveRequest) String 

func (m *QueueReceiveRequest) String() string

func (*QueueReceiveRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueReceiveRequest) XXX_DiscardUnknown()

func (*QueueReceiveRequest) XXX_Marshal added in v0.7.2 

func (m *QueueReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueReceiveRequest) XXX_Merge added in v0.7.2 

func (m *QueueReceiveRequest) XXX_Merge(src proto.Message)

func (*QueueReceiveRequest) XXX_Size added in v0.7.2 

func (m *QueueReceiveRequest) XXX_Size() int

func (*QueueReceiveRequest) XXX_Unmarshal added in v0.7.2 

func (m *QueueReceiveRequest) XXX_Unmarshal(b []byte) error

type QueueReceiveResponse 

type QueueReceiveResponse struct {
	// Array of tasks popped off the queue
	Tasks                []*NitricTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*QueueReceiveResponse) Descriptor 

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

func (*QueueReceiveResponse) GetTasks 

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

func (*QueueReceiveResponse) ProtoMessage 

func (*QueueReceiveResponse) ProtoMessage()

func (*QueueReceiveResponse) Reset 

func (m *QueueReceiveResponse) Reset()

func (*QueueReceiveResponse) String 

func (m *QueueReceiveResponse) String() string

func (*QueueReceiveResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueReceiveResponse) XXX_DiscardUnknown()

func (*QueueReceiveResponse) XXX_Marshal added in v0.7.2 

func (m *QueueReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueReceiveResponse) XXX_Merge added in v0.7.2 

func (m *QueueReceiveResponse) XXX_Merge(src proto.Message)

func (*QueueReceiveResponse) XXX_Size added in v0.7.2 

func (m *QueueReceiveResponse) XXX_Size() int

func (*QueueReceiveResponse) XXX_Unmarshal added in v0.7.2 

func (m *QueueReceiveResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*QueueSendBatchRequest) Descriptor 

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

func (*QueueSendBatchRequest) GetQueue 

func (m *QueueSendBatchRequest) GetQueue() string

func (*QueueSendBatchRequest) GetTasks 

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

func (*QueueSendBatchRequest) ProtoMessage 

func (*QueueSendBatchRequest) ProtoMessage()

func (*QueueSendBatchRequest) Reset 

func (m *QueueSendBatchRequest) Reset()

func (*QueueSendBatchRequest) String 

func (m *QueueSendBatchRequest) String() string

func (*QueueSendBatchRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueSendBatchRequest) XXX_DiscardUnknown()

func (*QueueSendBatchRequest) XXX_Marshal added in v0.7.2 

func (m *QueueSendBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueSendBatchRequest) XXX_Merge added in v0.7.2 

func (m *QueueSendBatchRequest) XXX_Merge(src proto.Message)

func (*QueueSendBatchRequest) XXX_Size added in v0.7.2 

func (m *QueueSendBatchRequest) XXX_Size() int

func (*QueueSendBatchRequest) XXX_Unmarshal added in v0.7.2 

func (m *QueueSendBatchRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Response for sending a collection of tasks

func (*QueueSendBatchResponse) Descriptor 

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

func (*QueueSendBatchResponse) GetFailedTasks 

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

func (*QueueSendBatchResponse) ProtoMessage 

func (*QueueSendBatchResponse) ProtoMessage()

func (*QueueSendBatchResponse) Reset 

func (m *QueueSendBatchResponse) Reset()

func (*QueueSendBatchResponse) String 

func (m *QueueSendBatchResponse) String() string

func (*QueueSendBatchResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueSendBatchResponse) XXX_DiscardUnknown()

func (*QueueSendBatchResponse) XXX_Marshal added in v0.7.2 

func (m *QueueSendBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueSendBatchResponse) XXX_Merge added in v0.7.2 

func (m *QueueSendBatchResponse) XXX_Merge(src proto.Message)

func (*QueueSendBatchResponse) XXX_Size added in v0.7.2 

func (m *QueueSendBatchResponse) XXX_Size() int

func (*QueueSendBatchResponse) XXX_Unmarshal added in v0.7.2 

func (m *QueueSendBatchResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Request to push a single event to a queue

func (*QueueSendRequest) Descriptor 

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

func (*QueueSendRequest) GetQueue 

func (m *QueueSendRequest) GetQueue() string

func (*QueueSendRequest) GetTask 

func (m *QueueSendRequest) GetTask() *NitricTask

func (*QueueSendRequest) ProtoMessage 

func (*QueueSendRequest) ProtoMessage()

func (*QueueSendRequest) Reset 

func (m *QueueSendRequest) Reset()

func (*QueueSendRequest) String 

func (m *QueueSendRequest) String() string

func (*QueueSendRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueSendRequest) XXX_DiscardUnknown()

func (*QueueSendRequest) XXX_Marshal added in v0.7.2 

func (m *QueueSendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueSendRequest) XXX_Merge added in v0.7.2 

func (m *QueueSendRequest) XXX_Merge(src proto.Message)

func (*QueueSendRequest) XXX_Size added in v0.7.2 

func (m *QueueSendRequest) XXX_Size() int

func (*QueueSendRequest) XXX_Unmarshal added in v0.7.2 

func (m *QueueSendRequest) XXX_Unmarshal(b []byte) error

type QueueSendResponse 

type QueueSendResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Result of pushing a single task to a queue

func (*QueueSendResponse) Descriptor 

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

func (*QueueSendResponse) ProtoMessage 

func (*QueueSendResponse) ProtoMessage()

func (*QueueSendResponse) Reset 

func (m *QueueSendResponse) Reset()

func (*QueueSendResponse) String 

func (m *QueueSendResponse) String() string

func (*QueueSendResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *QueueSendResponse) XXX_DiscardUnknown()

func (*QueueSendResponse) XXX_Marshal added in v0.7.2 

func (m *QueueSendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueSendResponse) XXX_Merge added in v0.7.2 

func (m *QueueSendResponse) XXX_Merge(src proto.Message)

func (*QueueSendResponse) XXX_Size added in v0.7.2 

func (m *QueueSendResponse) XXX_Size() int

func (*QueueSendResponse) XXX_Unmarshal added in v0.7.2 

func (m *QueueSendResponse) XXX_Unmarshal(b []byte) error

type QueueServiceClient added in v0.4.0 

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.

func NewQueueServiceClient added in v0.4.0 

func NewQueueServiceClient(cc grpc.ClientConnInterface) QueueServiceClient

type QueueServiceServer added in v0.4.0 

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)
}

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

type Secret added in v0.5.0 

type Secret struct {
	// The secret name
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The secret container

func (*Secret) Descriptor added in v0.5.0 

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

func (*Secret) GetName added in v0.5.0 

func (m *Secret) GetName() string

func (*Secret) ProtoMessage added in v0.5.0 

func (*Secret) ProtoMessage()

func (*Secret) Reset added in v0.5.0 

func (m *Secret) Reset()

func (*Secret) String added in v0.5.0 

func (m *Secret) String() string

func (*Secret) XXX_DiscardUnknown added in v0.7.2 

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal added in v0.7.2 

func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Secret) XXX_Merge added in v0.7.2 

func (m *Secret) XXX_Merge(src proto.Message)

func (*Secret) XXX_Size added in v0.7.2 

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal added in v0.7.2 

func (m *Secret) XXX_Unmarshal(b []byte) error

type SecretAccessRequest added in v0.5.0 

type SecretAccessRequest struct {
	// The id of the secret
	SecretVersion        *SecretVersion `protobuf:"bytes,1,opt,name=secret_version,json=secretVersion,proto3" json:"secret_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Request to get a secret from a Secret Store

func (*SecretAccessRequest) Descriptor added in v0.5.0 

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

func (*SecretAccessRequest) GetSecretVersion added in v0.5.0 

func (m *SecretAccessRequest) GetSecretVersion() *SecretVersion

func (*SecretAccessRequest) ProtoMessage added in v0.5.0 

func (*SecretAccessRequest) ProtoMessage()

func (*SecretAccessRequest) Reset added in v0.5.0 

func (m *SecretAccessRequest) Reset()

func (*SecretAccessRequest) String added in v0.5.0 

func (m *SecretAccessRequest) String() string

func (*SecretAccessRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *SecretAccessRequest) XXX_DiscardUnknown()

func (*SecretAccessRequest) XXX_Marshal added in v0.7.2 

func (m *SecretAccessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretAccessRequest) XXX_Merge added in v0.7.2 

func (m *SecretAccessRequest) XXX_Merge(src proto.Message)

func (*SecretAccessRequest) XXX_Size added in v0.7.2 

func (m *SecretAccessRequest) XXX_Size() int

func (*SecretAccessRequest) XXX_Unmarshal added in v0.7.2 

func (m *SecretAccessRequest) XXX_Unmarshal(b []byte) error

type SecretAccessResponse added in v0.5.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The secret response

func (*SecretAccessResponse) Descriptor added in v0.5.0 

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

func (*SecretAccessResponse) GetSecretVersion added in v0.5.0 

func (m *SecretAccessResponse) GetSecretVersion() *SecretVersion

func (*SecretAccessResponse) GetValue added in v0.5.0 

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

func (*SecretAccessResponse) ProtoMessage added in v0.5.0 

func (*SecretAccessResponse) ProtoMessage()

func (*SecretAccessResponse) Reset added in v0.5.0 

func (m *SecretAccessResponse) Reset()

func (*SecretAccessResponse) String added in v0.5.0 

func (m *SecretAccessResponse) String() string

func (*SecretAccessResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *SecretAccessResponse) XXX_DiscardUnknown()

func (*SecretAccessResponse) XXX_Marshal added in v0.7.2 

func (m *SecretAccessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretAccessResponse) XXX_Merge added in v0.7.2 

func (m *SecretAccessResponse) XXX_Merge(src proto.Message)

func (*SecretAccessResponse) XXX_Size added in v0.7.2 

func (m *SecretAccessResponse) XXX_Size() int

func (*SecretAccessResponse) XXX_Unmarshal added in v0.7.2 

func (m *SecretAccessResponse) XXX_Unmarshal(b []byte) error

type SecretPutRequest added in v0.5.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to put a secret to a Secret Store

func (*SecretPutRequest) Descriptor added in v0.5.0 

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

func (*SecretPutRequest) GetSecret added in v0.5.0 

func (m *SecretPutRequest) GetSecret() *Secret

func (*SecretPutRequest) GetValue added in v0.5.0 

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

func (*SecretPutRequest) ProtoMessage added in v0.5.0 

func (*SecretPutRequest) ProtoMessage()

func (*SecretPutRequest) Reset added in v0.5.0 

func (m *SecretPutRequest) Reset()

func (*SecretPutRequest) String added in v0.5.0 

func (m *SecretPutRequest) String() string

func (*SecretPutRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *SecretPutRequest) XXX_DiscardUnknown()

func (*SecretPutRequest) XXX_Marshal added in v0.7.2 

func (m *SecretPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretPutRequest) XXX_Merge added in v0.7.2 

func (m *SecretPutRequest) XXX_Merge(src proto.Message)

func (*SecretPutRequest) XXX_Size added in v0.7.2 

func (m *SecretPutRequest) XXX_Size() int

func (*SecretPutRequest) XXX_Unmarshal added in v0.7.2 

func (m *SecretPutRequest) XXX_Unmarshal(b []byte) error

type SecretPutResponse added in v0.5.0 

type SecretPutResponse struct {
	// The id of the secret
	SecretVersion        *SecretVersion `protobuf:"bytes,1,opt,name=secret_version,json=secretVersion,proto3" json:"secret_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Result from putting the secret to a Secret Store

func (*SecretPutResponse) Descriptor added in v0.5.0 

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

func (*SecretPutResponse) GetSecretVersion added in v0.5.0 

func (m *SecretPutResponse) GetSecretVersion() *SecretVersion

func (*SecretPutResponse) ProtoMessage added in v0.5.0 

func (*SecretPutResponse) ProtoMessage()

func (*SecretPutResponse) Reset added in v0.5.0 

func (m *SecretPutResponse) Reset()

func (*SecretPutResponse) String added in v0.5.0 

func (m *SecretPutResponse) String() string

func (*SecretPutResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *SecretPutResponse) XXX_DiscardUnknown()

func (*SecretPutResponse) XXX_Marshal added in v0.7.2 

func (m *SecretPutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretPutResponse) XXX_Merge added in v0.7.2 

func (m *SecretPutResponse) XXX_Merge(src proto.Message)

func (*SecretPutResponse) XXX_Size added in v0.7.2 

func (m *SecretPutResponse) XXX_Size() int

func (*SecretPutResponse) XXX_Unmarshal added in v0.7.2 

func (m *SecretPutResponse) XXX_Unmarshal(b []byte) error

type SecretServiceClient added in v0.5.0 

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.

func NewSecretServiceClient added in v0.5.0 

func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient

type SecretServiceServer added in v0.5.0 

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)
}

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

type SecretVersion added in v0.5.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A version of a secret

func (*SecretVersion) Descriptor added in v0.5.0 

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

func (*SecretVersion) GetSecret added in v0.5.0 

func (m *SecretVersion) GetSecret() *Secret

func (*SecretVersion) GetVersion added in v0.5.0 

func (m *SecretVersion) GetVersion() string

func (*SecretVersion) ProtoMessage added in v0.5.0 

func (*SecretVersion) ProtoMessage()

func (*SecretVersion) Reset added in v0.5.0 

func (m *SecretVersion) Reset()

func (*SecretVersion) String added in v0.5.0 

func (m *SecretVersion) String() string

func (*SecretVersion) XXX_DiscardUnknown added in v0.7.2 

func (m *SecretVersion) XXX_DiscardUnknown()

func (*SecretVersion) XXX_Marshal added in v0.7.2 

func (m *SecretVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretVersion) XXX_Merge added in v0.7.2 

func (m *SecretVersion) XXX_Merge(src proto.Message)

func (*SecretVersion) XXX_Size added in v0.7.2 

func (m *SecretVersion) XXX_Size() int

func (*SecretVersion) XXX_Unmarshal added in v0.7.2 

func (m *SecretVersion) XXX_Unmarshal(b []byte) error

type ServerMessage added in v0.3.0 

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 valid to be assigned to Content:
	//	*ServerMessage_InitResponse
	//	*ServerMessage_TriggerRequest
	Content              isServerMessage_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Messages the server is able to send to the client

func (*ServerMessage) Descriptor added in v0.3.0 

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

func (*ServerMessage) GetContent added in v0.3.0 

func (m *ServerMessage) GetContent() isServerMessage_Content

func (*ServerMessage) GetId added in v0.3.0 

func (m *ServerMessage) GetId() string

func (*ServerMessage) GetInitResponse added in v0.3.0 

func (m *ServerMessage) GetInitResponse() *InitResponse

func (*ServerMessage) GetTriggerRequest added in v0.3.0 

func (m *ServerMessage) GetTriggerRequest() *TriggerRequest

func (*ServerMessage) ProtoMessage added in v0.3.0 

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) Reset added in v0.3.0 

func (m *ServerMessage) Reset()

func (*ServerMessage) String added in v0.3.0 

func (m *ServerMessage) String() string

func (*ServerMessage) XXX_DiscardUnknown added in v0.7.2 

func (m *ServerMessage) XXX_DiscardUnknown()

func (*ServerMessage) XXX_Marshal added in v0.7.2 

func (m *ServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerMessage) XXX_Merge added in v0.7.2 

func (m *ServerMessage) XXX_Merge(src proto.Message)

func (*ServerMessage) XXX_OneofWrappers added in v0.7.2 

func (*ServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerMessage) XXX_Size added in v0.7.2 

func (m *ServerMessage) XXX_Size() int

func (*ServerMessage) XXX_Unmarshal added in v0.7.2 

func (m *ServerMessage) XXX_Unmarshal(b []byte) error

type ServerMessage_InitResponse added in v0.3.0 

type ServerMessage_InitResponse struct {
	InitResponse *InitResponse `protobuf:"bytes,2,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type ServerMessage_TriggerRequest added in v0.3.0 

type ServerMessage_TriggerRequest struct {
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to delete a storage item

func (*StorageDeleteRequest) Descriptor 

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

func (*StorageDeleteRequest) GetBucketName 

func (m *StorageDeleteRequest) GetBucketName() string

func (*StorageDeleteRequest) GetKey 

func (m *StorageDeleteRequest) GetKey() string

func (*StorageDeleteRequest) ProtoMessage 

func (*StorageDeleteRequest) ProtoMessage()

func (*StorageDeleteRequest) Reset 

func (m *StorageDeleteRequest) Reset()

func (*StorageDeleteRequest) String 

func (m *StorageDeleteRequest) String() string

func (*StorageDeleteRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageDeleteRequest) XXX_DiscardUnknown()

func (*StorageDeleteRequest) XXX_Marshal added in v0.7.2 

func (m *StorageDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageDeleteRequest) XXX_Merge added in v0.7.2 

func (m *StorageDeleteRequest) XXX_Merge(src proto.Message)

func (*StorageDeleteRequest) XXX_Size added in v0.7.2 

func (m *StorageDeleteRequest) XXX_Size() int

func (*StorageDeleteRequest) XXX_Unmarshal added in v0.7.2 

func (m *StorageDeleteRequest) XXX_Unmarshal(b []byte) error

type StorageDeleteResponse 

type StorageDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Result of deleting a storage item

func (*StorageDeleteResponse) Descriptor 

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

func (*StorageDeleteResponse) ProtoMessage 

func (*StorageDeleteResponse) ProtoMessage()

func (*StorageDeleteResponse) Reset 

func (m *StorageDeleteResponse) Reset()

func (*StorageDeleteResponse) String 

func (m *StorageDeleteResponse) String() string

func (*StorageDeleteResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageDeleteResponse) XXX_DiscardUnknown()

func (*StorageDeleteResponse) XXX_Marshal added in v0.7.2 

func (m *StorageDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageDeleteResponse) XXX_Merge added in v0.7.2 

func (m *StorageDeleteResponse) XXX_Merge(src proto.Message)

func (*StorageDeleteResponse) XXX_Size added in v0.7.2 

func (m *StorageDeleteResponse) XXX_Size() int

func (*StorageDeleteResponse) XXX_Unmarshal added in v0.7.2 

func (m *StorageDeleteResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to retrieve a storage item

func (*StorageReadRequest) Descriptor 

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

func (*StorageReadRequest) GetBucketName 

func (m *StorageReadRequest) GetBucketName() string

func (*StorageReadRequest) GetKey 

func (m *StorageReadRequest) GetKey() string

func (*StorageReadRequest) ProtoMessage 

func (*StorageReadRequest) ProtoMessage()

func (*StorageReadRequest) Reset 

func (m *StorageReadRequest) Reset()

func (*StorageReadRequest) String 

func (m *StorageReadRequest) String() string

func (*StorageReadRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageReadRequest) XXX_DiscardUnknown()

func (*StorageReadRequest) XXX_Marshal added in v0.7.2 

func (m *StorageReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageReadRequest) XXX_Merge added in v0.7.2 

func (m *StorageReadRequest) XXX_Merge(src proto.Message)

func (*StorageReadRequest) XXX_Size added in v0.7.2 

func (m *StorageReadRequest) XXX_Size() int

func (*StorageReadRequest) XXX_Unmarshal added in v0.7.2 

func (m *StorageReadRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Returned storage item

func (*StorageReadResponse) Descriptor 

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

func (*StorageReadResponse) GetBody 

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

func (*StorageReadResponse) ProtoMessage 

func (*StorageReadResponse) ProtoMessage()

func (*StorageReadResponse) Reset 

func (m *StorageReadResponse) Reset()

func (*StorageReadResponse) String 

func (m *StorageReadResponse) String() string

func (*StorageReadResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageReadResponse) XXX_DiscardUnknown()

func (*StorageReadResponse) XXX_Marshal added in v0.7.2 

func (m *StorageReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageReadResponse) XXX_Merge added in v0.7.2 

func (m *StorageReadResponse) XXX_Merge(src proto.Message)

func (*StorageReadResponse) XXX_Size added in v0.7.2 

func (m *StorageReadResponse) XXX_Size() int

func (*StorageReadResponse) XXX_Unmarshal added in v0.7.2 

func (m *StorageReadResponse) XXX_Unmarshal(b []byte) error

type StorageServiceClient added in v0.4.0 

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)
}

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.

func NewStorageServiceClient added in v0.4.0 

func NewStorageServiceClient(cc grpc.ClientConnInterface) StorageServiceClient

type StorageServiceServer added in v0.4.0 

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)
}

StorageServiceServer is the server API for StorageService service. All implementations should 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to put (create/update) a storage item

func (*StorageWriteRequest) Descriptor 

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

func (*StorageWriteRequest) GetBody 

func (m *StorageWriteRequest) GetBody() []byte

func (*StorageWriteRequest) GetBucketName 

func (m *StorageWriteRequest) GetBucketName() string

func (*StorageWriteRequest) GetKey 

func (m *StorageWriteRequest) GetKey() string

func (*StorageWriteRequest) ProtoMessage 

func (*StorageWriteRequest) ProtoMessage()

func (*StorageWriteRequest) Reset 

func (m *StorageWriteRequest) Reset()

func (*StorageWriteRequest) String 

func (m *StorageWriteRequest) String() string

func (*StorageWriteRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageWriteRequest) XXX_DiscardUnknown()

func (*StorageWriteRequest) XXX_Marshal added in v0.7.2 

func (m *StorageWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageWriteRequest) XXX_Merge added in v0.7.2 

func (m *StorageWriteRequest) XXX_Merge(src proto.Message)

func (*StorageWriteRequest) XXX_Size added in v0.7.2 

func (m *StorageWriteRequest) XXX_Size() int

func (*StorageWriteRequest) XXX_Unmarshal added in v0.7.2 

func (m *StorageWriteRequest) XXX_Unmarshal(b []byte) error

type StorageWriteResponse 

type StorageWriteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Result of putting a storage item

func (*StorageWriteResponse) Descriptor 

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

func (*StorageWriteResponse) ProtoMessage 

func (*StorageWriteResponse) ProtoMessage()

func (*StorageWriteResponse) Reset 

func (m *StorageWriteResponse) Reset()

func (*StorageWriteResponse) String 

func (m *StorageWriteResponse) String() string

func (*StorageWriteResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *StorageWriteResponse) XXX_DiscardUnknown()

func (*StorageWriteResponse) XXX_Marshal added in v0.7.2 

func (m *StorageWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageWriteResponse) XXX_Merge added in v0.7.2 

func (m *StorageWriteResponse) XXX_Merge(src proto.Message)

func (*StorageWriteResponse) XXX_Size added in v0.7.2 

func (m *StorageWriteResponse) XXX_Size() int

func (*StorageWriteResponse) XXX_Unmarshal added in v0.7.2 

func (m *StorageWriteResponse) XXX_Unmarshal(b []byte) error

type TopicListRequest 

type TopicListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the Topic List method

func (*TopicListRequest) Descriptor 

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

func (*TopicListRequest) ProtoMessage 

func (*TopicListRequest) ProtoMessage()

func (*TopicListRequest) Reset 

func (m *TopicListRequest) Reset()

func (*TopicListRequest) String 

func (m *TopicListRequest) String() string

func (*TopicListRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *TopicListRequest) XXX_DiscardUnknown()

func (*TopicListRequest) XXX_Marshal added in v0.7.2 

func (m *TopicListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicListRequest) XXX_Merge added in v0.7.2 

func (m *TopicListRequest) XXX_Merge(src proto.Message)

func (*TopicListRequest) XXX_Size added in v0.7.2 

func (m *TopicListRequest) XXX_Size() int

func (*TopicListRequest) XXX_Unmarshal added in v0.7.2 

func (m *TopicListRequest) XXX_Unmarshal(b []byte) error

type TopicListResponse 

type TopicListResponse struct {
	// The list of found topics
	Topics               []*NitricTopic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Topic List Response

func (*TopicListResponse) Descriptor 

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

func (*TopicListResponse) GetTopics 

func (m *TopicListResponse) GetTopics() []*NitricTopic

func (*TopicListResponse) ProtoMessage 

func (*TopicListResponse) ProtoMessage()

func (*TopicListResponse) Reset 

func (m *TopicListResponse) Reset()

func (*TopicListResponse) String 

func (m *TopicListResponse) String() string

func (*TopicListResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *TopicListResponse) XXX_DiscardUnknown()

func (*TopicListResponse) XXX_Marshal added in v0.7.2 

func (m *TopicListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicListResponse) XXX_Merge added in v0.7.2 

func (m *TopicListResponse) XXX_Merge(src proto.Message)

func (*TopicListResponse) XXX_Size added in v0.7.2 

func (m *TopicListResponse) XXX_Size() int

func (*TopicListResponse) XXX_Unmarshal added in v0.7.2 

func (m *TopicListResponse) XXX_Unmarshal(b []byte) error

type TopicResponseContext added in v0.3.0 

type TopicResponseContext struct {
	// Success status of the handled event
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Specific event response message We do not accept responses for events only whether or not they were successfully processed

func (*TopicResponseContext) Descriptor added in v0.3.0 

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

func (*TopicResponseContext) GetSuccess added in v0.3.0 

func (m *TopicResponseContext) GetSuccess() bool

func (*TopicResponseContext) ProtoMessage added in v0.3.0 

func (*TopicResponseContext) ProtoMessage()

func (*TopicResponseContext) Reset added in v0.3.0 

func (m *TopicResponseContext) Reset()

func (*TopicResponseContext) String added in v0.3.0 

func (m *TopicResponseContext) String() string

func (*TopicResponseContext) XXX_DiscardUnknown added in v0.7.2 

func (m *TopicResponseContext) XXX_DiscardUnknown()

func (*TopicResponseContext) XXX_Marshal added in v0.7.2 

func (m *TopicResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicResponseContext) XXX_Merge added in v0.7.2 

func (m *TopicResponseContext) XXX_Merge(src proto.Message)

func (*TopicResponseContext) XXX_Size added in v0.7.2 

func (m *TopicResponseContext) XXX_Size() int

func (*TopicResponseContext) XXX_Unmarshal added in v0.7.2 

func (m *TopicResponseContext) XXX_Unmarshal(b []byte) error

type TopicServiceClient added in v0.4.0 

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.

func NewTopicServiceClient added in v0.4.0 

func NewTopicServiceClient(cc grpc.ClientConnInterface) TopicServiceClient

type TopicServiceServer added in v0.4.0 

type TopicServiceServer interface {
	// Return a list of existing topics in the provider environment
	List(context.Context, *TopicListRequest) (*TopicListResponse, error)
}

TopicServiceServer is the server API for TopicService service. All implementations should embed UnimplementedTopicServiceServer for forward compatibility

type TopicTriggerContext added in v0.3.0 

type TopicTriggerContext struct {
	// The topic the message was published for
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopicTriggerContext) Descriptor added in v0.3.0 

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

func (*TopicTriggerContext) GetTopic added in v0.3.0 

func (m *TopicTriggerContext) GetTopic() string

func (*TopicTriggerContext) ProtoMessage added in v0.3.0 

func (*TopicTriggerContext) ProtoMessage()

func (*TopicTriggerContext) Reset added in v0.3.0 

func (m *TopicTriggerContext) Reset()

func (*TopicTriggerContext) String added in v0.3.0 

func (m *TopicTriggerContext) String() string

func (*TopicTriggerContext) XXX_DiscardUnknown added in v0.7.2 

func (m *TopicTriggerContext) XXX_DiscardUnknown()

func (*TopicTriggerContext) XXX_Marshal added in v0.7.2 

func (m *TopicTriggerContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicTriggerContext) XXX_Merge added in v0.7.2 

func (m *TopicTriggerContext) XXX_Merge(src proto.Message)

func (*TopicTriggerContext) XXX_Size added in v0.7.2 

func (m *TopicTriggerContext) XXX_Size() int

func (*TopicTriggerContext) XXX_Unmarshal added in v0.7.2 

func (m *TopicTriggerContext) XXX_Unmarshal(b []byte) error

type TriggerRequest added in v0.3.0 

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"`
	// The context of the trigger
	//
	// Types that are valid to be assigned to Context:
	//	*TriggerRequest_Http
	//	*TriggerRequest_Topic
	Context              isTriggerRequest_Context `protobuf_oneof:"context"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

The server has a trigger for the client to handle

func (*TriggerRequest) Descriptor added in v0.3.0 

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

func (*TriggerRequest) GetContext added in v0.3.0 

func (m *TriggerRequest) GetContext() isTriggerRequest_Context

func (*TriggerRequest) GetData added in v0.3.0 

func (m *TriggerRequest) GetData() []byte

func (*TriggerRequest) GetHttp added in v0.3.0 

func (m *TriggerRequest) GetHttp() *HttpTriggerContext

func (*TriggerRequest) GetMimeType added in v0.3.0 

func (m *TriggerRequest) GetMimeType() string

func (*TriggerRequest) GetTopic added in v0.3.0 

func (m *TriggerRequest) GetTopic() *TopicTriggerContext

func (*TriggerRequest) ProtoMessage added in v0.3.0 

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) Reset added in v0.3.0 

func (m *TriggerRequest) Reset()

func (*TriggerRequest) String added in v0.3.0 

func (m *TriggerRequest) String() string

func (*TriggerRequest) XXX_DiscardUnknown added in v0.7.2 

func (m *TriggerRequest) XXX_DiscardUnknown()

func (*TriggerRequest) XXX_Marshal added in v0.7.2 

func (m *TriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TriggerRequest) XXX_Merge added in v0.7.2 

func (m *TriggerRequest) XXX_Merge(src proto.Message)

func (*TriggerRequest) XXX_OneofWrappers added in v0.7.2 

func (*TriggerRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TriggerRequest) XXX_Size added in v0.7.2 

func (m *TriggerRequest) XXX_Size() int

func (*TriggerRequest) XXX_Unmarshal added in v0.7.2 

func (m *TriggerRequest) XXX_Unmarshal(b []byte) error

type TriggerRequest_Http added in v0.3.0 

type TriggerRequest_Http struct {
	Http *HttpTriggerContext `protobuf:"bytes,3,opt,name=http,proto3,oneof"`
}

type TriggerRequest_Topic added in v0.3.0 

type TriggerRequest_Topic struct {
	Topic *TopicTriggerContext `protobuf:"bytes,4,opt,name=topic,proto3,oneof"`
}

type TriggerResponse added in v0.3.0 

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 valid to be assigned to Context:
	//	*TriggerResponse_Http
	//	*TriggerResponse_Topic
	Context              isTriggerResponse_Context `protobuf_oneof:"context"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

The worker has successfully processed a trigger

func (*TriggerResponse) Descriptor added in v0.3.0 

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

func (*TriggerResponse) GetContext added in v0.3.0 

func (m *TriggerResponse) GetContext() isTriggerResponse_Context

func (*TriggerResponse) GetData added in v0.3.0 

func (m *TriggerResponse) GetData() []byte

func (*TriggerResponse) GetHttp added in v0.3.0 

func (m *TriggerResponse) GetHttp() *HttpResponseContext

func (*TriggerResponse) GetTopic added in v0.3.0 

func (m *TriggerResponse) GetTopic() *TopicResponseContext

func (*TriggerResponse) ProtoMessage added in v0.3.0 

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) Reset added in v0.3.0 

func (m *TriggerResponse) Reset()

func (*TriggerResponse) String added in v0.3.0 

func (m *TriggerResponse) String() string

func (*TriggerResponse) XXX_DiscardUnknown added in v0.7.2 

func (m *TriggerResponse) XXX_DiscardUnknown()

func (*TriggerResponse) XXX_Marshal added in v0.7.2 

func (m *TriggerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TriggerResponse) XXX_Merge added in v0.7.2 

func (m *TriggerResponse) XXX_Merge(src proto.Message)

func (*TriggerResponse) XXX_OneofWrappers added in v0.7.2 

func (*TriggerResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TriggerResponse) XXX_Size added in v0.7.2 

func (m *TriggerResponse) XXX_Size() int

func (*TriggerResponse) XXX_Unmarshal added in v0.7.2 

func (m *TriggerResponse) XXX_Unmarshal(b []byte) error

type TriggerResponse_Http added in v0.3.0 

type TriggerResponse_Http struct {
	Http *HttpResponseContext `protobuf:"bytes,10,opt,name=http,proto3,oneof"`
}

type TriggerResponse_Topic added in v0.3.0 

type TriggerResponse_Topic struct {
	Topic *TopicResponseContext `protobuf:"bytes,11,opt,name=topic,proto3,oneof"`
}

type UnimplementedDocumentServiceServer added in v0.4.0 

type UnimplementedDocumentServiceServer struct {
}

UnimplementedDocumentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDocumentServiceServer) Delete added in v0.4.0 

func (UnimplementedDocumentServiceServer) Delete(context.Context, *DocumentDeleteRequest) (*DocumentDeleteResponse, error)

func (UnimplementedDocumentServiceServer) Get added in v0.4.0 

func (UnimplementedDocumentServiceServer) Get(context.Context, *DocumentGetRequest) (*DocumentGetResponse, error)

func (UnimplementedDocumentServiceServer) Query added in v0.4.0 

func (UnimplementedDocumentServiceServer) Query(context.Context, *DocumentQueryRequest) (*DocumentQueryResponse, error)

func (UnimplementedDocumentServiceServer) QueryStream added in v0.4.0 

func (UnimplementedDocumentServiceServer) QueryStream(*DocumentQueryStreamRequest, DocumentService_QueryStreamServer) error

func (UnimplementedDocumentServiceServer) Set added in v0.4.0 

func (UnimplementedDocumentServiceServer) Set(context.Context, *DocumentSetRequest) (*DocumentSetResponse, error)

type UnimplementedEventServiceServer added in v0.4.0 

type UnimplementedEventServiceServer struct {
}

UnimplementedEventServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedEventServiceServer) Publish added in v0.4.0 

func (UnimplementedEventServiceServer) Publish(context.Context, *EventPublishRequest) (*EventPublishResponse, error)

type UnimplementedFaasServiceServer added in v0.4.0 

type UnimplementedFaasServiceServer struct {
}

UnimplementedFaasServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedFaasServiceServer) TriggerStream added in v0.4.0 

func (UnimplementedFaasServiceServer) TriggerStream(FaasService_TriggerStreamServer) error

type UnimplementedQueueServiceServer added in v0.4.0 

type UnimplementedQueueServiceServer struct {
}

UnimplementedQueueServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedQueueServiceServer) Complete added in v0.4.0 

func (UnimplementedQueueServiceServer) Complete(context.Context, *QueueCompleteRequest) (*QueueCompleteResponse, error)

func (UnimplementedQueueServiceServer) Receive added in v0.4.0 

func (UnimplementedQueueServiceServer) Receive(context.Context, *QueueReceiveRequest) (*QueueReceiveResponse, error)

func (UnimplementedQueueServiceServer) Send added in v0.4.0 

func (UnimplementedQueueServiceServer) Send(context.Context, *QueueSendRequest) (*QueueSendResponse, error)

func (UnimplementedQueueServiceServer) SendBatch added in v0.4.0 

func (UnimplementedQueueServiceServer) SendBatch(context.Context, *QueueSendBatchRequest) (*QueueSendBatchResponse, error)

type UnimplementedSecretServiceServer added in v0.5.0 

type UnimplementedSecretServiceServer struct {
}

UnimplementedSecretServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSecretServiceServer) Access added in v0.5.0 

func (UnimplementedSecretServiceServer) Access(context.Context, *SecretAccessRequest) (*SecretAccessResponse, error)

func (UnimplementedSecretServiceServer) Put added in v0.5.0 

func (UnimplementedSecretServiceServer) Put(context.Context, *SecretPutRequest) (*SecretPutResponse, error)

type UnimplementedStorageServiceServer added in v0.4.0 

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStorageServiceServer) Delete added in v0.4.0 

func (UnimplementedStorageServiceServer) Delete(context.Context, *StorageDeleteRequest) (*StorageDeleteResponse, error)

func (UnimplementedStorageServiceServer) Read added in v0.4.0 

func (UnimplementedStorageServiceServer) Read(context.Context, *StorageReadRequest) (*StorageReadResponse, error)

func (UnimplementedStorageServiceServer) Write added in v0.4.0 

func (UnimplementedStorageServiceServer) Write(context.Context, *StorageWriteRequest) (*StorageWriteResponse, error)

type UnimplementedTopicServiceServer added in v0.4.0 

type UnimplementedTopicServiceServer struct {
}

UnimplementedTopicServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTopicServiceServer) List added in v0.4.0 

func (UnimplementedTopicServiceServer) List(context.Context, *TopicListRequest) (*TopicListResponse, error)

type UnsafeDocumentServiceServer added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 UnsafeSecretServiceServer added in v0.5.0 

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 added in v0.4.0 

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 added in v0.4.0 

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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