v1

package

Go to main page

Versions in this module

v0

v0.7.2

Sep 9, 2021

Changes in this version

type ClientMessage

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientMessage) XXX_DiscardUnknown()

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

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

+ func (m *ClientMessage) XXX_Size() int

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

type Collection

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Collection) XXX_DiscardUnknown()

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

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

+ func (m *Collection) XXX_Size() int

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

type Document

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Document) XXX_DiscardUnknown()

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

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

+ func (m *Document) XXX_Size() int

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

type DocumentDeleteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentDeleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *DocumentDeleteRequest) XXX_Size() int

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

type DocumentDeleteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentDeleteResponse) XXX_DiscardUnknown()

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

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

+ func (m *DocumentDeleteResponse) XXX_Size() int

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

type DocumentGetRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentGetRequest) XXX_DiscardUnknown()

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

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

+ func (m *DocumentGetRequest) XXX_Size() int

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

type DocumentGetResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentGetResponse) XXX_DiscardUnknown()

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

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

+ func (m *DocumentGetResponse) XXX_Size() int

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

type DocumentQueryRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentQueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *DocumentQueryRequest) XXX_Size() int

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

type DocumentQueryResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentQueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *DocumentQueryResponse) XXX_Size() int

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

type DocumentQueryStreamRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentQueryStreamRequest) XXX_DiscardUnknown()

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

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

+ func (m *DocumentQueryStreamRequest) XXX_Size() int

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

type DocumentQueryStreamResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentQueryStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *DocumentQueryStreamResponse) XXX_Size() int

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

type DocumentSetRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentSetRequest) XXX_DiscardUnknown()

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

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

+ func (m *DocumentSetRequest) XXX_Size() int

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

type DocumentSetResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DocumentSetResponse) XXX_DiscardUnknown()

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

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

+ func (m *DocumentSetResponse) XXX_Size() int

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

type EventPublishRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *EventPublishRequest) XXX_DiscardUnknown()

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

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

+ func (m *EventPublishRequest) XXX_Size() int

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

type EventPublishResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *EventPublishResponse) XXX_DiscardUnknown()

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

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

+ func (m *EventPublishResponse) XXX_Size() int

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

type Expression

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Expression) XXX_DiscardUnknown()

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

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

+ func (m *Expression) XXX_Size() int

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

type ExpressionValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ExpressionValue) XXX_DiscardUnknown()

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

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

+ func (m *ExpressionValue) XXX_Size() int

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

type FailedTask

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FailedTask) XXX_DiscardUnknown()

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

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

+ func (m *FailedTask) XXX_Size() int

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

+ type HeaderValue struct

+ Value []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HeaderValue) ProtoMessage()

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

+ func (m *HeaderValue) Reset()

+ func (m *HeaderValue) String() string

+ func (m *HeaderValue) XXX_DiscardUnknown()

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

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

+ func (m *HeaderValue) XXX_Size() int

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

type HttpResponseContext

+ HeadersOld map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HttpResponseContext) XXX_DiscardUnknown()

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

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

+ func (m *HttpResponseContext) XXX_Size() int

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

type HttpTriggerContext

+ HeadersOld map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *HttpTriggerContext) XXX_DiscardUnknown()

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

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

+ func (m *HttpTriggerContext) XXX_Size() int

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

type InitRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *InitRequest) XXX_DiscardUnknown()

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

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

+ func (m *InitRequest) XXX_Size() int

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

type InitResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *InitResponse) XXX_DiscardUnknown()

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

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

+ func (m *InitResponse) XXX_Size() int

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

type Key

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Key) XXX_DiscardUnknown()

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

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

+ func (m *Key) XXX_Size() int

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

type NitricEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *NitricEvent) XXX_DiscardUnknown()

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

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

+ func (m *NitricEvent) XXX_Size() int

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

type NitricTask

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *NitricTask) XXX_DiscardUnknown()

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

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

+ func (m *NitricTask) XXX_Size() int

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

type NitricTopic

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *NitricTopic) XXX_DiscardUnknown()

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

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

+ func (m *NitricTopic) XXX_Size() int

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

type QueueCompleteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueCompleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueCompleteRequest) XXX_Size() int

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

type QueueCompleteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueCompleteResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueCompleteResponse) XXX_Size() int

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

type QueueReceiveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueReceiveRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueReceiveRequest) XXX_Size() int

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

type QueueReceiveResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueReceiveResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueReceiveResponse) XXX_Size() int

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

type QueueSendBatchRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueSendBatchRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueSendBatchRequest) XXX_Size() int

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

type QueueSendBatchResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueSendBatchResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueSendBatchResponse) XXX_Size() int

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

type QueueSendRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueSendRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueSendRequest) XXX_Size() int

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

type QueueSendResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *QueueSendResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueSendResponse) XXX_Size() int

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

type Secret

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Secret) XXX_DiscardUnknown()

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

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

+ func (m *Secret) XXX_Size() int

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

type SecretAccessRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SecretAccessRequest) XXX_DiscardUnknown()

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

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

+ func (m *SecretAccessRequest) XXX_Size() int

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

type SecretAccessResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SecretAccessResponse) XXX_DiscardUnknown()

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

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

+ func (m *SecretAccessResponse) XXX_Size() int

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

type SecretPutRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SecretPutRequest) XXX_DiscardUnknown()

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

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

+ func (m *SecretPutRequest) XXX_Size() int

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

type SecretPutResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SecretPutResponse) XXX_DiscardUnknown()

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

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

+ func (m *SecretPutResponse) XXX_Size() int

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

type SecretVersion

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SecretVersion) XXX_DiscardUnknown()

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

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

+ func (m *SecretVersion) XXX_Size() int

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

type ServerMessage

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerMessage) XXX_DiscardUnknown()

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

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

+ func (m *ServerMessage) XXX_Size() int

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

type StorageDeleteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageDeleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *StorageDeleteRequest) XXX_Size() int

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

type StorageDeleteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageDeleteResponse) XXX_DiscardUnknown()

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

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

+ func (m *StorageDeleteResponse) XXX_Size() int

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

type StorageReadRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageReadRequest) XXX_DiscardUnknown()

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

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

+ func (m *StorageReadRequest) XXX_Size() int

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

type StorageReadResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageReadResponse) XXX_DiscardUnknown()

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

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

+ func (m *StorageReadResponse) XXX_Size() int

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

type StorageWriteRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageWriteRequest) XXX_DiscardUnknown()

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

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

+ func (m *StorageWriteRequest) XXX_Size() int

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

type StorageWriteResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StorageWriteResponse) XXX_DiscardUnknown()

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

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

+ func (m *StorageWriteResponse) XXX_Size() int

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

type TopicListRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TopicListRequest) XXX_DiscardUnknown()

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

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

+ func (m *TopicListRequest) XXX_Size() int

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

type TopicListResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TopicListResponse) XXX_DiscardUnknown()

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

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

+ func (m *TopicListResponse) XXX_Size() int

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

type TopicResponseContext

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TopicResponseContext) XXX_DiscardUnknown()

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

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

+ func (m *TopicResponseContext) XXX_Size() int

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

type TopicTriggerContext

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TopicTriggerContext) XXX_DiscardUnknown()

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

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

+ func (m *TopicTriggerContext) XXX_Size() int

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

type TriggerRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TriggerRequest) XXX_DiscardUnknown()

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

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

+ func (m *TriggerRequest) XXX_Size() int

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

type TriggerResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TriggerResponse) XXX_DiscardUnknown()

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

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

+ func (m *TriggerResponse) XXX_Size() int

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

v0.7.1

Aug 10, 2021

v0.7.0

Aug 6, 2021

v0.6.1

Aug 6, 2021

v0.6.0

Aug 6, 2021

v0.5.2

Aug 5, 2021

v0.5.1

Jul 30, 2021

v0.5.0

Jul 30, 2021

Changes in this version

+ var File_secret_v1_secret_proto protoreflect.FileDescriptor

+ var SecretService_ServiceDesc = grpc.ServiceDesc

+ func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

+ type Secret struct

+ Name string

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

+ func (*Secret) ProtoMessage()

+ func (x *Secret) GetName() string

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

+ func (x *Secret) Reset()

+ func (x *Secret) String() string

+ type SecretAccessRequest struct

+ SecretVersion *SecretVersion

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

+ func (*SecretAccessRequest) ProtoMessage()

+ func (x *SecretAccessRequest) GetSecretVersion() *SecretVersion

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

+ func (x *SecretAccessRequest) Reset()

+ func (x *SecretAccessRequest) String() string

+ type SecretAccessResponse struct

+ SecretVersion *SecretVersion

+ Value []byte

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

+ func (*SecretAccessResponse) ProtoMessage()

+ func (x *SecretAccessResponse) GetSecretVersion() *SecretVersion

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

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

+ func (x *SecretAccessResponse) Reset()

+ func (x *SecretAccessResponse) String() string

+ type SecretPutRequest struct

+ Secret *Secret

+ Value []byte

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

+ func (*SecretPutRequest) ProtoMessage()

+ func (x *SecretPutRequest) GetSecret() *Secret

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

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

+ func (x *SecretPutRequest) Reset()

+ func (x *SecretPutRequest) String() string

+ type SecretPutResponse struct

+ SecretVersion *SecretVersion

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

+ func (*SecretPutResponse) ProtoMessage()

+ func (x *SecretPutResponse) GetSecretVersion() *SecretVersion

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

+ func (x *SecretPutResponse) Reset()

+ func (x *SecretPutResponse) String() string

+ type SecretServiceClient interface

+ Access func(ctx context.Context, in *SecretAccessRequest, opts ...grpc.CallOption) (*SecretAccessResponse, error)

+ Put func(ctx context.Context, in *SecretPutRequest, opts ...grpc.CallOption) (*SecretPutResponse, error)

+ func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient

+ type SecretServiceServer interface

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

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

+ type SecretVersion struct

+ Secret *Secret

+ Version string

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

+ func (*SecretVersion) ProtoMessage()

+ func (x *SecretVersion) GetSecret() *Secret

+ func (x *SecretVersion) GetVersion() string

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

+ func (x *SecretVersion) Reset()

+ func (x *SecretVersion) String() string

+ type UnimplementedSecretServiceServer struct

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

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

+ type UnsafeSecretServiceServer interface

v0.4.0

Jul 23, 2021

Changes in this version

+ var DocumentService_ServiceDesc = grpc.ServiceDesc

+ var EventService_ServiceDesc = grpc.ServiceDesc

+ var FaasService_ServiceDesc = grpc.ServiceDesc

+ var File_document_v1_document_proto protoreflect.FileDescriptor

+ var QueueService_ServiceDesc = grpc.ServiceDesc

+ var StorageService_ServiceDesc = grpc.ServiceDesc

+ var TopicService_ServiceDesc = grpc.ServiceDesc

+ func RegisterDocumentServiceServer(s grpc.ServiceRegistrar, srv DocumentServiceServer)

+ func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

+ func RegisterFaasServiceServer(s grpc.ServiceRegistrar, srv FaasServiceServer)

+ func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)

+ func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)

+ func RegisterTopicServiceServer(s grpc.ServiceRegistrar, srv TopicServiceServer)

+ type Collection struct

+ Name string

+ Parent *Key

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

+ func (*Collection) ProtoMessage()

+ func (x *Collection) GetName() string

+ func (x *Collection) GetParent() *Key

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

+ func (x *Collection) Reset()

+ func (x *Collection) String() string

+ type Document struct

+ Content *structpb.Struct

+ Key *Key

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

+ func (*Document) ProtoMessage()

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

+ func (x *Document) GetKey() *Key

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

+ func (x *Document) Reset()

+ func (x *Document) String() string

+ type DocumentDeleteRequest struct

+ Key *Key

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

+ func (*DocumentDeleteRequest) ProtoMessage()

+ func (x *DocumentDeleteRequest) GetKey() *Key

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

+ func (x *DocumentDeleteRequest) Reset()

+ func (x *DocumentDeleteRequest) String() string

+ type DocumentDeleteResponse struct

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

+ func (*DocumentDeleteResponse) ProtoMessage()

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

+ func (x *DocumentDeleteResponse) Reset()

+ func (x *DocumentDeleteResponse) String() string

+ type DocumentGetRequest struct

+ Key *Key

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

+ func (*DocumentGetRequest) ProtoMessage()

+ func (x *DocumentGetRequest) GetKey() *Key

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

+ func (x *DocumentGetRequest) Reset()

+ func (x *DocumentGetRequest) String() string

+ type DocumentGetResponse struct

+ Document *Document

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

+ func (*DocumentGetResponse) ProtoMessage()

+ func (x *DocumentGetResponse) GetDocument() *Document

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

+ func (x *DocumentGetResponse) Reset()

+ func (x *DocumentGetResponse) String() string

+ type DocumentQueryRequest struct

+ Collection *Collection

+ Expressions []*Expression

+ Limit int32

+ PagingToken map[string]string

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

+ func (*DocumentQueryRequest) ProtoMessage()

+ func (x *DocumentQueryRequest) GetCollection() *Collection

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

+ func (x *DocumentQueryRequest) GetLimit() int32

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

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

+ func (x *DocumentQueryRequest) Reset()

+ func (x *DocumentQueryRequest) String() string

+ type DocumentQueryResponse struct

+ Documents []*Document

+ PagingToken map[string]string

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

+ func (*DocumentQueryResponse) ProtoMessage()

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

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

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

+ func (x *DocumentQueryResponse) Reset()

+ func (x *DocumentQueryResponse) String() string

+ type DocumentQueryStreamRequest struct

+ Collection *Collection

+ Expressions []*Expression

+ Limit int32

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

+ func (*DocumentQueryStreamRequest) ProtoMessage()

+ func (x *DocumentQueryStreamRequest) GetCollection() *Collection

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

+ func (x *DocumentQueryStreamRequest) GetLimit() int32

+ func (x *DocumentQueryStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *DocumentQueryStreamRequest) Reset()

+ func (x *DocumentQueryStreamRequest) String() string

+ type DocumentQueryStreamResponse struct

+ Document *Document

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

+ func (*DocumentQueryStreamResponse) ProtoMessage()

+ func (x *DocumentQueryStreamResponse) GetDocument() *Document

+ func (x *DocumentQueryStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *DocumentQueryStreamResponse) Reset()

+ func (x *DocumentQueryStreamResponse) String() string

+ type DocumentServiceClient interface

+ Delete func(ctx context.Context, in *DocumentDeleteRequest, opts ...grpc.CallOption) (*DocumentDeleteResponse, error)

+ Get func(ctx context.Context, in *DocumentGetRequest, opts ...grpc.CallOption) (*DocumentGetResponse, error)

+ Query func(ctx context.Context, in *DocumentQueryRequest, opts ...grpc.CallOption) (*DocumentQueryResponse, error)

+ QueryStream func(ctx context.Context, in *DocumentQueryStreamRequest, opts ...grpc.CallOption) (DocumentService_QueryStreamClient, error)

+ Set func(ctx context.Context, in *DocumentSetRequest, opts ...grpc.CallOption) (*DocumentSetResponse, error)

+ func NewDocumentServiceClient(cc grpc.ClientConnInterface) DocumentServiceClient

+ type DocumentServiceServer interface

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

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

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

+ QueryStream func(*DocumentQueryStreamRequest, DocumentService_QueryStreamServer) error

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

+ type DocumentService_QueryStreamClient interface

+ Recv func() (*DocumentQueryStreamResponse, error)

+ type DocumentService_QueryStreamServer interface

+ Send func(*DocumentQueryStreamResponse) error

+ type DocumentSetRequest struct

+ Content *structpb.Struct

+ Key *Key

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

+ func (*DocumentSetRequest) ProtoMessage()

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

+ func (x *DocumentSetRequest) GetKey() *Key

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

+ func (x *DocumentSetRequest) Reset()

+ func (x *DocumentSetRequest) String() string

+ type DocumentSetResponse struct

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

+ func (*DocumentSetResponse) ProtoMessage()

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

+ func (x *DocumentSetResponse) Reset()

+ func (x *DocumentSetResponse) String() string

+ type EventServiceClient interface

+ Publish func(ctx context.Context, in *EventPublishRequest, opts ...grpc.CallOption) (*EventPublishResponse, error)

+ func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

+ type EventServiceServer interface

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

+ type Expression struct

+ Operand string

+ Operator string

+ Value *ExpressionValue

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

+ func (*Expression) ProtoMessage()

+ func (x *Expression) GetOperand() string

+ func (x *Expression) GetOperator() string

+ func (x *Expression) GetValue() *ExpressionValue

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

+ func (x *Expression) Reset()

+ func (x *Expression) String() string

+ type ExpressionValue struct

+ Kind isExpressionValue_Kind

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

+ func (*ExpressionValue) ProtoMessage()

+ func (m *ExpressionValue) GetKind() isExpressionValue_Kind

+ func (x *ExpressionValue) GetBoolValue() bool

+ func (x *ExpressionValue) GetDoubleValue() float64

+ func (x *ExpressionValue) GetIntValue() int64

+ func (x *ExpressionValue) GetStringValue() string

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

+ func (x *ExpressionValue) Reset()

+ func (x *ExpressionValue) String() string

+ type ExpressionValue_BoolValue struct

+ BoolValue bool

+ type ExpressionValue_DoubleValue struct

+ DoubleValue float64

+ type ExpressionValue_IntValue struct

+ IntValue int64

+ type ExpressionValue_StringValue struct

+ StringValue string

+ type FaasServiceClient interface

+ TriggerStream func(ctx context.Context, opts ...grpc.CallOption) (FaasService_TriggerStreamClient, error)

+ func NewFaasServiceClient(cc grpc.ClientConnInterface) FaasServiceClient

+ type FaasServiceServer interface

+ TriggerStream func(FaasService_TriggerStreamServer) error

+ type FaasService_TriggerStreamClient interface

+ Recv func() (*ServerMessage, error)

+ Send func(*ClientMessage) error

+ type FaasService_TriggerStreamServer interface

+ Recv func() (*ClientMessage, error)

+ Send func(*ServerMessage) error

+ type Key struct

+ Collection *Collection

+ Id string

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

+ func (*Key) ProtoMessage()

+ func (x *Key) GetCollection() *Collection

+ func (x *Key) GetId() string

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

+ func (x *Key) Reset()

+ func (x *Key) String() string

+ type QueueServiceClient interface

+ Complete func(ctx context.Context, in *QueueCompleteRequest, opts ...grpc.CallOption) (*QueueCompleteResponse, error)

+ Receive func(ctx context.Context, in *QueueReceiveRequest, opts ...grpc.CallOption) (*QueueReceiveResponse, error)

+ Send func(ctx context.Context, in *QueueSendRequest, opts ...grpc.CallOption) (*QueueSendResponse, error)

+ SendBatch func(ctx context.Context, in *QueueSendBatchRequest, opts ...grpc.CallOption) (*QueueSendBatchResponse, error)

+ func NewQueueServiceClient(cc grpc.ClientConnInterface) QueueServiceClient

+ type QueueServiceServer interface

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

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

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

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

+ type StorageServiceClient interface

+ Delete func(ctx context.Context, in *StorageDeleteRequest, opts ...grpc.CallOption) (*StorageDeleteResponse, error)

+ Read func(ctx context.Context, in *StorageReadRequest, opts ...grpc.CallOption) (*StorageReadResponse, error)

+ Write func(ctx context.Context, in *StorageWriteRequest, opts ...grpc.CallOption) (*StorageWriteResponse, error)

+ func NewStorageServiceClient(cc grpc.ClientConnInterface) StorageServiceClient

+ type StorageServiceServer interface

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

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

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

+ type TopicServiceClient interface

+ List func(ctx context.Context, in *TopicListRequest, opts ...grpc.CallOption) (*TopicListResponse, error)

+ func NewTopicServiceClient(cc grpc.ClientConnInterface) TopicServiceClient

+ type TopicServiceServer interface

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

+ type UnimplementedDocumentServiceServer struct

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

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

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

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

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

+ type UnimplementedEventServiceServer struct

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

+ type UnimplementedFaasServiceServer struct

+ func (UnimplementedFaasServiceServer) TriggerStream(FaasService_TriggerStreamServer) error

+ type UnimplementedQueueServiceServer struct

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

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

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

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

+ type UnimplementedStorageServiceServer struct

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

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

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

+ type UnimplementedTopicServiceServer struct

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

+ type UnsafeDocumentServiceServer interface

+ type UnsafeEventServiceServer interface

+ type UnsafeFaasServiceServer interface

+ type UnsafeQueueServiceServer interface

+ type UnsafeStorageServiceServer interface

+ type UnsafeTopicServiceServer interface

v0.3.1

Jul 15, 2021

v0.3.0

Jun 18, 2021

Changes in this version

+ var Faas_ServiceDesc = grpc.ServiceDesc

+ var File_faas_v1_faas_proto protoreflect.FileDescriptor

+ func RegisterFaasServer(s grpc.ServiceRegistrar, srv FaasServer)

+ type ClientMessage struct

+ Content isClientMessage_Content

+ Id string

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

+ func (*ClientMessage) ProtoMessage()

+ func (m *ClientMessage) GetContent() isClientMessage_Content

+ func (x *ClientMessage) GetId() string

+ func (x *ClientMessage) GetInitRequest() *InitRequest

+ func (x *ClientMessage) GetTriggerResponse() *TriggerResponse

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

+ func (x *ClientMessage) Reset()

+ func (x *ClientMessage) String() string

+ type ClientMessage_InitRequest struct

+ InitRequest *InitRequest

+ type ClientMessage_TriggerResponse struct

+ TriggerResponse *TriggerResponse

+ type FaasClient interface

+ TriggerStream func(ctx context.Context, opts ...grpc.CallOption) (Faas_TriggerStreamClient, error)

+ func NewFaasClient(cc grpc.ClientConnInterface) FaasClient

+ type FaasServer interface

+ TriggerStream func(Faas_TriggerStreamServer) error

+ type Faas_TriggerStreamClient interface

+ Recv func() (*ServerMessage, error)

+ Send func(*ClientMessage) error

+ type Faas_TriggerStreamServer interface

+ Recv func() (*ClientMessage, error)

+ Send func(*ServerMessage) error

+ type HttpResponseContext struct

+ Headers map[string]string

+ Status int32

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

+ func (*HttpResponseContext) ProtoMessage()

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

+ func (x *HttpResponseContext) GetStatus() int32

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

+ func (x *HttpResponseContext) Reset()

+ func (x *HttpResponseContext) String() string

+ type HttpTriggerContext struct

+ Headers map[string]string

+ Method string

+ Path string

+ QueryParams map[string]string

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

+ func (*HttpTriggerContext) ProtoMessage()

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

+ func (x *HttpTriggerContext) GetMethod() string

+ func (x *HttpTriggerContext) GetPath() string

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

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

+ func (x *HttpTriggerContext) Reset()

+ func (x *HttpTriggerContext) String() string

+ type InitRequest struct

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

+ func (*InitRequest) ProtoMessage()

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

+ func (x *InitRequest) Reset()

+ func (x *InitRequest) String() string

+ type InitResponse struct

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

+ func (*InitResponse) ProtoMessage()

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

+ func (x *InitResponse) Reset()

+ func (x *InitResponse) String() string

+ type ServerMessage struct

+ Content isServerMessage_Content

+ Id string

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

+ func (*ServerMessage) ProtoMessage()

+ func (m *ServerMessage) GetContent() isServerMessage_Content

+ func (x *ServerMessage) GetId() string

+ func (x *ServerMessage) GetInitResponse() *InitResponse

+ func (x *ServerMessage) GetTriggerRequest() *TriggerRequest

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

+ func (x *ServerMessage) Reset()

+ func (x *ServerMessage) String() string

+ type ServerMessage_InitResponse struct

+ InitResponse *InitResponse

+ type ServerMessage_TriggerRequest struct

+ TriggerRequest *TriggerRequest

+ type TopicResponseContext struct

+ Success bool

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

+ func (*TopicResponseContext) ProtoMessage()

+ func (x *TopicResponseContext) GetSuccess() bool

+ func (x *TopicResponseContext) ProtoReflect() protoreflect.Message

+ func (x *TopicResponseContext) Reset()

+ func (x *TopicResponseContext) String() string

+ type TopicTriggerContext struct

+ Topic string

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

+ func (*TopicTriggerContext) ProtoMessage()

+ func (x *TopicTriggerContext) GetTopic() string

+ func (x *TopicTriggerContext) ProtoReflect() protoreflect.Message

+ func (x *TopicTriggerContext) Reset()

+ func (x *TopicTriggerContext) String() string

+ type TriggerRequest struct

+ Context isTriggerRequest_Context

+ Data []byte

+ MimeType string

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

+ func (*TriggerRequest) ProtoMessage()

+ func (m *TriggerRequest) GetContext() isTriggerRequest_Context

+ func (x *TriggerRequest) GetData() []byte

+ func (x *TriggerRequest) GetHttp() *HttpTriggerContext

+ func (x *TriggerRequest) GetMimeType() string

+ func (x *TriggerRequest) GetTopic() *TopicTriggerContext

+ func (x *TriggerRequest) ProtoReflect() protoreflect.Message

+ func (x *TriggerRequest) Reset()

+ func (x *TriggerRequest) String() string

+ type TriggerRequest_Http struct

+ Http *HttpTriggerContext

+ type TriggerRequest_Topic struct

+ Topic *TopicTriggerContext

+ type TriggerResponse struct

+ Context isTriggerResponse_Context

+ Data []byte

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

+ func (*TriggerResponse) ProtoMessage()

+ func (m *TriggerResponse) GetContext() isTriggerResponse_Context

+ func (x *TriggerResponse) GetData() []byte

+ func (x *TriggerResponse) GetHttp() *HttpResponseContext

+ func (x *TriggerResponse) GetTopic() *TopicResponseContext

+ func (x *TriggerResponse) ProtoReflect() protoreflect.Message

+ func (x *TriggerResponse) Reset()

+ func (x *TriggerResponse) String() string

+ type TriggerResponse_Http struct

+ Http *HttpResponseContext

+ type TriggerResponse_Topic struct

+ Topic *TopicResponseContext

+ type UnimplementedFaasServer struct

+ func (UnimplementedFaasServer) TriggerStream(Faas_TriggerStreamServer) error

+ type UnsafeFaasServer interface

v0.2.0

May 19, 2021

Changes in this version

+ var Event_ServiceDesc = grpc.ServiceDesc

+ var File_auth_v1_auth_proto protoreflect.FileDescriptor

+ var File_event_v1_event_proto protoreflect.FileDescriptor

+ var File_kv_v1_kv_proto protoreflect.FileDescriptor

+ var File_queue_v1_queue_proto protoreflect.FileDescriptor

+ var File_storage_v1_storage_proto protoreflect.FileDescriptor

+ var KeyValue_ServiceDesc = grpc.ServiceDesc

+ var Queue_ServiceDesc = grpc.ServiceDesc

+ var Storage_ServiceDesc = grpc.ServiceDesc

+ var Topic_ServiceDesc = grpc.ServiceDesc

+ var User_ServiceDesc = grpc.ServiceDesc

+ func RegisterEventServer(s grpc.ServiceRegistrar, srv EventServer)

+ func RegisterKeyValueServer(s grpc.ServiceRegistrar, srv KeyValueServer)

+ func RegisterQueueServer(s grpc.ServiceRegistrar, srv QueueServer)

+ func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)

+ func RegisterTopicServer(s grpc.ServiceRegistrar, srv TopicServer)

+ func RegisterUserServer(s grpc.ServiceRegistrar, srv UserServer)

+ type EventClient interface

+ Publish func(ctx context.Context, in *EventPublishRequest, opts ...grpc.CallOption) (*EventPublishResponse, error)

+ func NewEventClient(cc grpc.ClientConnInterface) EventClient

+ type EventPublishRequest struct

+ Event *NitricEvent

+ Topic string

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

+ func (*EventPublishRequest) ProtoMessage()

+ func (x *EventPublishRequest) GetEvent() *NitricEvent

+ func (x *EventPublishRequest) GetTopic() string

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

+ func (x *EventPublishRequest) Reset()

+ func (x *EventPublishRequest) String() string

+ type EventPublishResponse struct

+ Id string

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

+ func (*EventPublishResponse) ProtoMessage()

+ func (x *EventPublishResponse) GetId() string

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

+ func (x *EventPublishResponse) Reset()

+ func (x *EventPublishResponse) String() string

+ type EventServer interface

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

+ type FailedTask struct

+ Message string

+ Task *NitricTask

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

+ func (*FailedTask) ProtoMessage()

+ func (x *FailedTask) GetMessage() string

+ func (x *FailedTask) GetTask() *NitricTask

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

+ func (x *FailedTask) Reset()

+ func (x *FailedTask) String() string

+ type KeyValueClient interface

+ Delete func(ctx context.Context, in *KeyValueDeleteRequest, opts ...grpc.CallOption) (*KeyValueDeleteResponse, error)

+ Get func(ctx context.Context, in *KeyValueGetRequest, opts ...grpc.CallOption) (*KeyValueGetResponse, error)

+ Put func(ctx context.Context, in *KeyValuePutRequest, opts ...grpc.CallOption) (*KeyValuePutResponse, error)

+ func NewKeyValueClient(cc grpc.ClientConnInterface) KeyValueClient

+ type KeyValueDeleteRequest struct

+ Collection string

+ Key string

+ func (*KeyValueDeleteRequest) Descriptor() ([]byte, []int)

+ func (*KeyValueDeleteRequest) ProtoMessage()

+ func (x *KeyValueDeleteRequest) GetCollection() string

+ func (x *KeyValueDeleteRequest) GetKey() string

+ func (x *KeyValueDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyValueDeleteRequest) Reset()

+ func (x *KeyValueDeleteRequest) String() string

+ type KeyValueDeleteResponse struct

+ func (*KeyValueDeleteResponse) Descriptor() ([]byte, []int)

+ func (*KeyValueDeleteResponse) ProtoMessage()

+ func (x *KeyValueDeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *KeyValueDeleteResponse) Reset()

+ func (x *KeyValueDeleteResponse) String() string

+ type KeyValueGetRequest struct

+ Collection string

+ Key string

+ func (*KeyValueGetRequest) Descriptor() ([]byte, []int)

+ func (*KeyValueGetRequest) ProtoMessage()

+ func (x *KeyValueGetRequest) GetCollection() string

+ func (x *KeyValueGetRequest) GetKey() string

+ func (x *KeyValueGetRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyValueGetRequest) Reset()

+ func (x *KeyValueGetRequest) String() string

+ type KeyValueGetResponse struct

+ Value *structpb.Struct

+ func (*KeyValueGetResponse) Descriptor() ([]byte, []int)

+ func (*KeyValueGetResponse) ProtoMessage()

+ func (x *KeyValueGetResponse) GetValue() *structpb.Struct

+ func (x *KeyValueGetResponse) ProtoReflect() protoreflect.Message

+ func (x *KeyValueGetResponse) Reset()

+ func (x *KeyValueGetResponse) String() string

+ type KeyValuePutRequest struct

+ Collection string

+ Key string

+ Value *structpb.Struct

+ func (*KeyValuePutRequest) Descriptor() ([]byte, []int)

+ func (*KeyValuePutRequest) ProtoMessage()

+ func (x *KeyValuePutRequest) GetCollection() string

+ func (x *KeyValuePutRequest) GetKey() string

+ func (x *KeyValuePutRequest) GetValue() *structpb.Struct

+ func (x *KeyValuePutRequest) ProtoReflect() protoreflect.Message

+ func (x *KeyValuePutRequest) Reset()

+ func (x *KeyValuePutRequest) String() string

+ type KeyValuePutResponse struct

+ func (*KeyValuePutResponse) Descriptor() ([]byte, []int)

+ func (*KeyValuePutResponse) ProtoMessage()

+ func (x *KeyValuePutResponse) ProtoReflect() protoreflect.Message

+ func (x *KeyValuePutResponse) Reset()

+ func (x *KeyValuePutResponse) String() string

+ type KeyValueServer interface

+ Delete func(context.Context, *KeyValueDeleteRequest) (*KeyValueDeleteResponse, error)

+ Get func(context.Context, *KeyValueGetRequest) (*KeyValueGetResponse, error)

+ Put func(context.Context, *KeyValuePutRequest) (*KeyValuePutResponse, error)

+ type NitricEvent struct

+ Id string

+ Payload *structpb.Struct

+ PayloadType string

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

+ func (*NitricEvent) ProtoMessage()

+ func (x *NitricEvent) GetId() string

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

+ func (x *NitricEvent) GetPayloadType() string

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

+ func (x *NitricEvent) Reset()

+ func (x *NitricEvent) String() string

+ type NitricTask struct

+ Id string

+ LeaseId string

+ Payload *structpb.Struct

+ PayloadType string

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

+ func (*NitricTask) ProtoMessage()

+ func (x *NitricTask) GetId() string

+ func (x *NitricTask) GetLeaseId() string

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

+ func (x *NitricTask) GetPayloadType() string

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

+ func (x *NitricTask) Reset()

+ func (x *NitricTask) String() string

+ type NitricTopic struct

+ Name string

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

+ func (*NitricTopic) ProtoMessage()

+ func (x *NitricTopic) GetName() string

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

+ func (x *NitricTopic) Reset()

+ func (x *NitricTopic) String() string

+ type QueueClient interface

+ Complete func(ctx context.Context, in *QueueCompleteRequest, opts ...grpc.CallOption) (*QueueCompleteResponse, error)

+ Receive func(ctx context.Context, in *QueueReceiveRequest, opts ...grpc.CallOption) (*QueueReceiveResponse, error)

+ Send func(ctx context.Context, in *QueueSendRequest, opts ...grpc.CallOption) (*QueueSendResponse, error)

+ SendBatch func(ctx context.Context, in *QueueSendBatchRequest, opts ...grpc.CallOption) (*QueueSendBatchResponse, error)

+ func NewQueueClient(cc grpc.ClientConnInterface) QueueClient

+ type QueueCompleteRequest struct

+ LeaseId string

+ Queue string

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

+ func (*QueueCompleteRequest) ProtoMessage()

+ func (x *QueueCompleteRequest) GetLeaseId() string

+ func (x *QueueCompleteRequest) GetQueue() string

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

+ func (x *QueueCompleteRequest) Reset()

+ func (x *QueueCompleteRequest) String() string

+ type QueueCompleteResponse struct

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

+ func (*QueueCompleteResponse) ProtoMessage()

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

+ func (x *QueueCompleteResponse) Reset()

+ func (x *QueueCompleteResponse) String() string

+ type QueueReceiveRequest struct

+ Depth int32

+ Queue string

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

+ func (*QueueReceiveRequest) ProtoMessage()

+ func (x *QueueReceiveRequest) GetDepth() int32

+ func (x *QueueReceiveRequest) GetQueue() string

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

+ func (x *QueueReceiveRequest) Reset()

+ func (x *QueueReceiveRequest) String() string

+ type QueueReceiveResponse struct

+ Tasks []*NitricTask

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

+ func (*QueueReceiveResponse) ProtoMessage()

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

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

+ func (x *QueueReceiveResponse) Reset()

+ func (x *QueueReceiveResponse) String() string

+ type QueueSendBatchRequest struct

+ Queue string

+ Tasks []*NitricTask

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

+ func (*QueueSendBatchRequest) ProtoMessage()

+ func (x *QueueSendBatchRequest) GetQueue() string

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

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

+ func (x *QueueSendBatchRequest) Reset()

+ func (x *QueueSendBatchRequest) String() string

+ type QueueSendBatchResponse struct

+ FailedTasks []*FailedTask

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

+ func (*QueueSendBatchResponse) ProtoMessage()

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

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

+ func (x *QueueSendBatchResponse) Reset()

+ func (x *QueueSendBatchResponse) String() string

+ type QueueSendRequest struct

+ Queue string

+ Task *NitricTask

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

+ func (*QueueSendRequest) ProtoMessage()

+ func (x *QueueSendRequest) GetQueue() string

+ func (x *QueueSendRequest) GetTask() *NitricTask

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

+ func (x *QueueSendRequest) Reset()

+ func (x *QueueSendRequest) String() string

+ type QueueSendResponse struct

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

+ func (*QueueSendResponse) ProtoMessage()

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

+ func (x *QueueSendResponse) Reset()

+ func (x *QueueSendResponse) String() string

+ type QueueServer interface

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

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

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

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

+ type StorageClient interface

+ Delete func(ctx context.Context, in *StorageDeleteRequest, opts ...grpc.CallOption) (*StorageDeleteResponse, error)

+ Read func(ctx context.Context, in *StorageReadRequest, opts ...grpc.CallOption) (*StorageReadResponse, error)

+ Write func(ctx context.Context, in *StorageWriteRequest, opts ...grpc.CallOption) (*StorageWriteResponse, error)

+ func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

+ type StorageDeleteRequest struct

+ BucketName string

+ Key string

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

+ func (*StorageDeleteRequest) ProtoMessage()

+ func (x *StorageDeleteRequest) GetBucketName() string

+ func (x *StorageDeleteRequest) GetKey() string

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

+ func (x *StorageDeleteRequest) Reset()

+ func (x *StorageDeleteRequest) String() string

+ type StorageDeleteResponse struct

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

+ func (*StorageDeleteResponse) ProtoMessage()

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

+ func (x *StorageDeleteResponse) Reset()

+ func (x *StorageDeleteResponse) String() string

+ type StorageReadRequest struct

+ BucketName string

+ Key string

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

+ func (*StorageReadRequest) ProtoMessage()

+ func (x *StorageReadRequest) GetBucketName() string

+ func (x *StorageReadRequest) GetKey() string

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

+ func (x *StorageReadRequest) Reset()

+ func (x *StorageReadRequest) String() string

+ type StorageReadResponse struct

+ Body []byte

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

+ func (*StorageReadResponse) ProtoMessage()

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

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

+ func (x *StorageReadResponse) Reset()

+ func (x *StorageReadResponse) String() string

+ type StorageServer interface

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

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

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

+ type StorageWriteRequest struct

+ Body []byte

+ BucketName string

+ Key string

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

+ func (*StorageWriteRequest) ProtoMessage()

+ func (x *StorageWriteRequest) GetBody() []byte

+ func (x *StorageWriteRequest) GetBucketName() string

+ func (x *StorageWriteRequest) GetKey() string

+ func (x *StorageWriteRequest) ProtoReflect() protoreflect.Message

+ func (x *StorageWriteRequest) Reset()

+ func (x *StorageWriteRequest) String() string

+ type StorageWriteResponse struct

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

+ func (*StorageWriteResponse) ProtoMessage()

+ func (x *StorageWriteResponse) ProtoReflect() protoreflect.Message

+ func (x *StorageWriteResponse) Reset()

+ func (x *StorageWriteResponse) String() string

+ type TopicClient interface

+ List func(ctx context.Context, in *TopicListRequest, opts ...grpc.CallOption) (*TopicListResponse, error)

+ func NewTopicClient(cc grpc.ClientConnInterface) TopicClient

+ type TopicListRequest struct

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

+ func (*TopicListRequest) ProtoMessage()

+ func (x *TopicListRequest) ProtoReflect() protoreflect.Message

+ func (x *TopicListRequest) Reset()

+ func (x *TopicListRequest) String() string

+ type TopicListResponse struct

+ Topics []*NitricTopic

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

+ func (*TopicListResponse) ProtoMessage()

+ func (x *TopicListResponse) GetTopics() []*NitricTopic

+ func (x *TopicListResponse) ProtoReflect() protoreflect.Message

+ func (x *TopicListResponse) Reset()

+ func (x *TopicListResponse) String() string

+ type TopicServer interface

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

+ type UnimplementedEventServer struct

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

+ type UnimplementedKeyValueServer struct

+ func (UnimplementedKeyValueServer) Delete(context.Context, *KeyValueDeleteRequest) (*KeyValueDeleteResponse, error)

+ func (UnimplementedKeyValueServer) Get(context.Context, *KeyValueGetRequest) (*KeyValueGetResponse, error)

+ func (UnimplementedKeyValueServer) Put(context.Context, *KeyValuePutRequest) (*KeyValuePutResponse, error)

+ type UnimplementedQueueServer struct

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

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

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

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

+ type UnimplementedStorageServer struct

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

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

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

+ type UnimplementedTopicServer struct

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

+ type UnimplementedUserServer struct

+ func (UnimplementedUserServer) Create(context.Context, *UserCreateRequest) (*UserCreateResponse, error)

+ type UnsafeEventServer interface

+ type UnsafeKeyValueServer interface

+ type UnsafeQueueServer interface

+ type UnsafeStorageServer interface

+ type UnsafeTopicServer interface

+ type UnsafeUserServer interface

+ type UserClient interface

+ Create func(ctx context.Context, in *UserCreateRequest, opts ...grpc.CallOption) (*UserCreateResponse, error)

+ func NewUserClient(cc grpc.ClientConnInterface) UserClient

+ type UserCreateRequest struct

+ Email string

+ Id string

+ Password string

+ Tenant string

+ func (*UserCreateRequest) Descriptor() ([]byte, []int)

+ func (*UserCreateRequest) ProtoMessage()

+ func (x *UserCreateRequest) GetEmail() string

+ func (x *UserCreateRequest) GetId() string

+ func (x *UserCreateRequest) GetPassword() string

+ func (x *UserCreateRequest) GetTenant() string

+ func (x *UserCreateRequest) ProtoReflect() protoreflect.Message

+ func (x *UserCreateRequest) Reset()

+ func (x *UserCreateRequest) String() string

+ type UserCreateResponse struct

+ func (*UserCreateResponse) Descriptor() ([]byte, []int)

+ func (*UserCreateResponse) ProtoMessage()

+ func (x *UserCreateResponse) ProtoReflect() protoreflect.Message

+ func (x *UserCreateResponse) Reset()

+ func (x *UserCreateResponse) String() string

+ type UserServer interface

+ Create func(context.Context, *UserCreateRequest) (*UserCreateResponse, error)

v0.1.3

Apr 1, 2021

v0.1.2

Mar 30, 2021

v0.1.1

Feb 22, 2021

v0.1.0

Feb 22, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL