runtime

package
v0.8.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2020 License: MIT Imports: 9 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BindingEventResponse_BindingEventConcurrency_name = map[int32]string{
	0: "SEQUENTIAL",
	1: "PARALLEL",
}
View Source 
var BindingEventResponse_BindingEventConcurrency_value = map[string]int32{
	"SEQUENTIAL": 0,
	"PARALLEL":   1,
}

Functions

func RegisterAppCallbackServer 

func RegisterAppCallbackServer(s *grpc.Server, srv AppCallbackServer)

func RegisterDaprServer 

func RegisterDaprServer(s *grpc.Server, srv DaprServer)

Types

type AppCallbackClient 

type AppCallbackClient interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error)
	// Listens events from the input bindings
	//
	// User application can save the states or send the events to the output
	// bindings optionally by returning BindingEventResponse.
	OnBindingEvent(ctx context.Context, in *BindingEventRequest, opts ...grpc.CallOption) (*BindingEventResponse, error)
}

AppCallbackClient is the client API for AppCallback service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAppCallbackClient 

func NewAppCallbackClient(cc *grpc.ClientConn) AppCallbackClient

type AppCallbackServer 

type AppCallbackServer interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(context.Context, *empty.Empty) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *TopicEventRequest) (*empty.Empty, error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(context.Context, *empty.Empty) (*ListInputBindingsResponse, error)
	// Listens events from the input bindings
	//
	// User application can save the states or send the events to the output
	// bindings optionally by returning BindingEventResponse.
	OnBindingEvent(context.Context, *BindingEventRequest) (*BindingEventResponse, error)
}

AppCallbackServer is the server API for AppCallback service.

type BindingEventRequest 

type BindingEventRequest struct {
	// Requried. The name of the input binding component.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The payload that the input bindings sent
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata set by the input binging components.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

BindingEventRequest represents input bindings event.

func (*BindingEventRequest) Descriptor 

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

func (*BindingEventRequest) GetData 

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

func (*BindingEventRequest) GetMetadata 

func (m *BindingEventRequest) GetMetadata() map[string]string

func (*BindingEventRequest) GetName 

func (m *BindingEventRequest) GetName() string

func (*BindingEventRequest) ProtoMessage 

func (*BindingEventRequest) ProtoMessage()

func (*BindingEventRequest) Reset 

func (m *BindingEventRequest) Reset()

func (*BindingEventRequest) String 

func (m *BindingEventRequest) String() string

func (*BindingEventRequest) XXX_DiscardUnknown 

func (m *BindingEventRequest) XXX_DiscardUnknown()

func (*BindingEventRequest) XXX_Marshal 

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

func (*BindingEventRequest) XXX_Merge 

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

func (*BindingEventRequest) XXX_Size 

func (m *BindingEventRequest) XXX_Size() int

func (*BindingEventRequest) XXX_Unmarshal 

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

type BindingEventResponse 

type BindingEventResponse struct {
	// The name of state store where states are saved.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The state key values which will be stored in store_name.
	States []*v1.StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// The list of output bindings.
	To []string `protobuf:"bytes,3,rep,name=to,proto3" json:"to,omitempty"`
	// The content which will be sent to "to" output bindings.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// The concurrency of output bindings to send data to
	// "to" output bindings list. The default is SEQUENTIAL.
	Concurrency          BindingEventResponse_BindingEventConcurrency `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

BindingEventResponse includes operations to save state or send data to output bindings optionally.

func (*BindingEventResponse) Descriptor 

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

func (*BindingEventResponse) GetConcurrency 

func (m *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

func (*BindingEventResponse) GetData 

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

func (*BindingEventResponse) GetStates 

func (m *BindingEventResponse) GetStates() []*v1.StateItem

func (*BindingEventResponse) GetStoreName 

func (m *BindingEventResponse) GetStoreName() string

func (*BindingEventResponse) GetTo 

func (m *BindingEventResponse) GetTo() []string

func (*BindingEventResponse) ProtoMessage 

func (*BindingEventResponse) ProtoMessage()

func (*BindingEventResponse) Reset 

func (m *BindingEventResponse) Reset()

func (*BindingEventResponse) String 

func (m *BindingEventResponse) String() string

func (*BindingEventResponse) XXX_DiscardUnknown 

func (m *BindingEventResponse) XXX_DiscardUnknown()

func (*BindingEventResponse) XXX_Marshal 

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

func (*BindingEventResponse) XXX_Merge 

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

func (*BindingEventResponse) XXX_Size 

func (m *BindingEventResponse) XXX_Size() int

func (*BindingEventResponse) XXX_Unmarshal 

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

type BindingEventResponse_BindingEventConcurrency 

type BindingEventResponse_BindingEventConcurrency int32

BindingEventConcurrency is the kind of concurrency 

const (
	// SEQUENTIAL sends data to output bindings specified in "to" sequentially.
	BindingEventResponse_SEQUENTIAL BindingEventResponse_BindingEventConcurrency = 0
	// PARALLEL sends data to output bindings specified in "to" in parallel.
	BindingEventResponse_PARALLEL BindingEventResponse_BindingEventConcurrency = 1
)

func (BindingEventResponse_BindingEventConcurrency) EnumDescriptor 

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

func (BindingEventResponse_BindingEventConcurrency) String 

func (x BindingEventResponse_BindingEventConcurrency) String() string

type DaprClient 

type DaprClient interface {
	// Invokes a method on a remote Dapr app.
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	// Gets the state for a specific key.
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	// Saves the state for a specific key.
	SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
}

DaprClient is the client API for Dapr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDaprClient 

func NewDaprClient(cc *grpc.ClientConn) DaprClient

type DaprServer 

type DaprServer interface {
	// Invokes a method on a remote Dapr app.
	InvokeService(context.Context, *InvokeServiceRequest) (*v1.InvokeResponse, error)
	// Gets the state for a specific key.
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// Saves the state for a specific key.
	SaveState(context.Context, *SaveStateRequest) (*empty.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *DeleteStateRequest) (*empty.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(context.Context, *PublishEventRequest) (*empty.Empty, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
}

DaprServer is the server API for Dapr service.

type DeleteStateRequest 

type DeleteStateRequest struct {
	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The entity tag which represents the specific version of data.
	// The exact ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// State operation options which includes concurrency/
	// consistency/retry_policy.
	Options              *v1.StateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

DeleteStateRequest is the message to delete key-value states in the specific state store.

func (*DeleteStateRequest) Descriptor 

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

func (*DeleteStateRequest) GetEtag 

func (m *DeleteStateRequest) GetEtag() string

func (*DeleteStateRequest) GetKey 

func (m *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) GetOptions 

func (m *DeleteStateRequest) GetOptions() *v1.StateOptions

func (*DeleteStateRequest) GetStoreName 

func (m *DeleteStateRequest) GetStoreName() string

func (*DeleteStateRequest) ProtoMessage 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) Reset 

func (m *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (m *DeleteStateRequest) String() string

func (*DeleteStateRequest) XXX_DiscardUnknown 

func (m *DeleteStateRequest) XXX_DiscardUnknown()

func (*DeleteStateRequest) XXX_Marshal 

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

func (*DeleteStateRequest) XXX_Merge 

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

func (*DeleteStateRequest) XXX_Size 

func (m *DeleteStateRequest) XXX_Size() int

func (*DeleteStateRequest) XXX_Unmarshal 

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

type GetSecretRequest 

type GetSecretRequest struct {
	// The name of secret store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of secret key.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The metadata which will be sent to secret store components.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) Descriptor 

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

func (*GetSecretRequest) GetKey 

func (m *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata 

func (m *GetSecretRequest) GetMetadata() map[string]string

func (*GetSecretRequest) GetStoreName 

func (m *GetSecretRequest) GetStoreName() string

func (*GetSecretRequest) ProtoMessage 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) Reset 

func (m *GetSecretRequest) Reset()

func (*GetSecretRequest) String 

func (m *GetSecretRequest) String() string

func (*GetSecretRequest) XXX_DiscardUnknown 

func (m *GetSecretRequest) XXX_DiscardUnknown()

func (*GetSecretRequest) XXX_Marshal 

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

func (*GetSecretRequest) XXX_Merge 

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

func (*GetSecretRequest) XXX_Size 

func (m *GetSecretRequest) XXX_Size() int

func (*GetSecretRequest) XXX_Unmarshal 

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

type GetSecretResponse 

type GetSecretResponse struct {
	// data is the secret value. Some secret store, such as kubernetes secret
	// store, can save multiple secrets for single secret key.
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

GetSecretResponse is the response mesage to convey the requested secret.

func (*GetSecretResponse) Descriptor 

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

func (*GetSecretResponse) GetData 

func (m *GetSecretResponse) GetData() map[string]string

func (*GetSecretResponse) ProtoMessage 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) Reset 

func (m *GetSecretResponse) Reset()

func (*GetSecretResponse) String 

func (m *GetSecretResponse) String() string

func (*GetSecretResponse) XXX_DiscardUnknown 

func (m *GetSecretResponse) XXX_DiscardUnknown()

func (*GetSecretResponse) XXX_Marshal 

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

func (*GetSecretResponse) XXX_Merge 

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

func (*GetSecretResponse) XXX_Size 

func (m *GetSecretResponse) XXX_Size() int

func (*GetSecretResponse) XXX_Unmarshal 

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

type GetStateRequest 

type GetStateRequest struct {
	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The read consistency of the state store.
	Consistency          v1.StateOptions_StateConsistency `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

GetStateRequest is the message to get key-value states from specific state store.

func (*GetStateRequest) Descriptor 

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

func (*GetStateRequest) GetConsistency 

func (m *GetStateRequest) GetConsistency() v1.StateOptions_StateConsistency

func (*GetStateRequest) GetKey 

func (m *GetStateRequest) GetKey() string

func (*GetStateRequest) GetStoreName 

func (m *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) Reset 

func (m *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (m *GetStateRequest) String() string

func (*GetStateRequest) XXX_DiscardUnknown 

func (m *GetStateRequest) XXX_DiscardUnknown()

func (*GetStateRequest) XXX_Marshal 

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

func (*GetStateRequest) XXX_Merge 

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

func (*GetStateRequest) XXX_Size 

func (m *GetStateRequest) XXX_Size() int

func (*GetStateRequest) XXX_Unmarshal 

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

type GetStateResponse 

type GetStateResponse struct {
	// The byte array data
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag                 string   `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStateResponse is the response conveying the state value and etag.

func (*GetStateResponse) Descriptor 

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

func (*GetStateResponse) GetData 

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

func (*GetStateResponse) GetEtag 

func (m *GetStateResponse) GetEtag() string

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) Reset 

func (m *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (m *GetStateResponse) String() string

func (*GetStateResponse) XXX_DiscardUnknown 

func (m *GetStateResponse) XXX_DiscardUnknown()

func (*GetStateResponse) XXX_Marshal 

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

func (*GetStateResponse) XXX_Merge 

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

func (*GetStateResponse) XXX_Size 

func (m *GetStateResponse) XXX_Size() int

func (*GetStateResponse) XXX_Unmarshal 

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

type InvokeBindingRequest 

type InvokeBindingRequest struct {
	// The name of the output binding to invoke.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata passing to output binding components
	//
	// Common metadata property:
	// - ttlInSeconds : the time to live in seconds for the message.
	// If set in the binding definition will cause all messages to
	// have a default time to live. The message ttl overrides any value
	// in the binding definition.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The name of the operation type for the binding to invoke
	Operation            string   `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InvokeBindingRequest is the message to send data to output bindings

func (*InvokeBindingRequest) Descriptor 

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

func (*InvokeBindingRequest) GetData 

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

func (*InvokeBindingRequest) GetMetadata 

func (m *InvokeBindingRequest) GetMetadata() map[string]string

func (*InvokeBindingRequest) GetName 

func (m *InvokeBindingRequest) GetName() string

func (*InvokeBindingRequest) GetOperation 

func (m *InvokeBindingRequest) GetOperation() string

func (*InvokeBindingRequest) ProtoMessage 

func (*InvokeBindingRequest) ProtoMessage()

func (*InvokeBindingRequest) Reset 

func (m *InvokeBindingRequest) Reset()

func (*InvokeBindingRequest) String 

func (m *InvokeBindingRequest) String() string

func (*InvokeBindingRequest) XXX_DiscardUnknown 

func (m *InvokeBindingRequest) XXX_DiscardUnknown()

func (*InvokeBindingRequest) XXX_Marshal 

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

func (*InvokeBindingRequest) XXX_Merge 

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

func (*InvokeBindingRequest) XXX_Size 

func (m *InvokeBindingRequest) XXX_Size() int

func (*InvokeBindingRequest) XXX_Unmarshal 

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

type InvokeBindingResponse 

type InvokeBindingResponse struct {
	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata returned from an external system
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

InvokeBindingResponse is the message returned from an output binding invocation

func (*InvokeBindingResponse) Descriptor 

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

func (*InvokeBindingResponse) GetData 

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

func (*InvokeBindingResponse) GetMetadata 

func (m *InvokeBindingResponse) GetMetadata() map[string]string

func (*InvokeBindingResponse) ProtoMessage 

func (*InvokeBindingResponse) ProtoMessage()

func (*InvokeBindingResponse) Reset 

func (m *InvokeBindingResponse) Reset()

func (*InvokeBindingResponse) String 

func (m *InvokeBindingResponse) String() string

func (*InvokeBindingResponse) XXX_DiscardUnknown 

func (m *InvokeBindingResponse) XXX_DiscardUnknown()

func (*InvokeBindingResponse) XXX_Marshal 

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

func (*InvokeBindingResponse) XXX_Merge 

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

func (*InvokeBindingResponse) XXX_Size 

func (m *InvokeBindingResponse) XXX_Size() int

func (*InvokeBindingResponse) XXX_Unmarshal 

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

type InvokeServiceRequest 

type InvokeServiceRequest struct {
	// Required. Callee's app id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required. message which will be delivered to callee.
	Message              *v1.InvokeRequest `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

InvokeServiceRequest represents the request message for Service invocation.

func (*InvokeServiceRequest) Descriptor 

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

func (*InvokeServiceRequest) GetId 

func (m *InvokeServiceRequest) GetId() string

func (*InvokeServiceRequest) GetMessage 

func (m *InvokeServiceRequest) GetMessage() *v1.InvokeRequest

func (*InvokeServiceRequest) ProtoMessage 

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) Reset 

func (m *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String 

func (m *InvokeServiceRequest) String() string

func (*InvokeServiceRequest) XXX_DiscardUnknown 

func (m *InvokeServiceRequest) XXX_DiscardUnknown()

func (*InvokeServiceRequest) XXX_Marshal 

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

func (*InvokeServiceRequest) XXX_Merge 

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

func (*InvokeServiceRequest) XXX_Size 

func (m *InvokeServiceRequest) XXX_Size() int

func (*InvokeServiceRequest) XXX_Unmarshal 

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

type ListInputBindingsResponse 

type ListInputBindingsResponse struct {
	// The list of input bindings.
	Bindings             []string `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListInputBindingsResponse is the message including the list of input bindings.

func (*ListInputBindingsResponse) Descriptor 

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

func (*ListInputBindingsResponse) GetBindings 

func (m *ListInputBindingsResponse) GetBindings() []string

func (*ListInputBindingsResponse) ProtoMessage 

func (*ListInputBindingsResponse) ProtoMessage()

func (*ListInputBindingsResponse) Reset 

func (m *ListInputBindingsResponse) Reset()

func (*ListInputBindingsResponse) String 

func (m *ListInputBindingsResponse) String() string

func (*ListInputBindingsResponse) XXX_DiscardUnknown 

func (m *ListInputBindingsResponse) XXX_DiscardUnknown()

func (*ListInputBindingsResponse) XXX_Marshal 

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

func (*ListInputBindingsResponse) XXX_Merge 

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

func (*ListInputBindingsResponse) XXX_Size 

func (m *ListInputBindingsResponse) XXX_Size() int

func (*ListInputBindingsResponse) XXX_Unmarshal 

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

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {
	// The list of topics.
	Subscriptions        []*TopicSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ListTopicSubscriptionsResponse is the message including the list of the subscribing topics.

func (*ListTopicSubscriptionsResponse) Descriptor 

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

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

func (m *ListTopicSubscriptionsResponse) GetSubscriptions() []*TopicSubscription

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) Reset 

func (m *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (m *ListTopicSubscriptionsResponse) String() string

func (*ListTopicSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListTopicSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListTopicSubscriptionsResponse) XXX_Marshal 

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

func (*ListTopicSubscriptionsResponse) XXX_Merge 

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

func (*ListTopicSubscriptionsResponse) XXX_Size 

func (m *ListTopicSubscriptionsResponse) XXX_Size() int

func (*ListTopicSubscriptionsResponse) XXX_Unmarshal 

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

type PublishEventRequest 

type PublishEventRequest struct {
	// The pubsub topic
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The data which will be published to topic.
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PublishEventRequest is the message to publish event data to pubsub topic

func (*PublishEventRequest) Descriptor 

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

func (*PublishEventRequest) GetData 

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

func (*PublishEventRequest) GetTopic 

func (m *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) Reset 

func (m *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (m *PublishEventRequest) String() string

func (*PublishEventRequest) XXX_DiscardUnknown 

func (m *PublishEventRequest) XXX_DiscardUnknown()

func (*PublishEventRequest) XXX_Marshal 

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

func (*PublishEventRequest) XXX_Merge 

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

func (*PublishEventRequest) XXX_Size 

func (m *PublishEventRequest) XXX_Size() int

func (*PublishEventRequest) XXX_Unmarshal 

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

type SaveStateRequest 

type SaveStateRequest struct {
	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The array of the state key values.
	States               []*v1.StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

SaveStateRequest is the message to save multiple states into state store.

func (*SaveStateRequest) Descriptor 

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

func (*SaveStateRequest) GetStates 

func (m *SaveStateRequest) GetStates() []*v1.StateItem

func (*SaveStateRequest) GetStoreName 

func (m *SaveStateRequest) GetStoreName() string

func (*SaveStateRequest) ProtoMessage 

func (*SaveStateRequest) ProtoMessage()

func (*SaveStateRequest) Reset 

func (m *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (m *SaveStateRequest) String() string

func (*SaveStateRequest) XXX_DiscardUnknown 

func (m *SaveStateRequest) XXX_DiscardUnknown()

func (*SaveStateRequest) XXX_Marshal 

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

func (*SaveStateRequest) XXX_Merge 

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

func (*SaveStateRequest) XXX_Size 

func (m *SaveStateRequest) XXX_Size() int

func (*SaveStateRequest) XXX_Unmarshal 

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

type TopicEventRequest 

type TopicEventRequest struct {
	// id identifies the event. Producers MUST ensure that source + id
	// is unique for each distinct event. If a duplicate event is re-sent
	// (e.g. due to a network error) it MAY have the same id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// source identifies the context in which an event happened.
	// Often this will include information such as the type of the
	// event source, the organization publishing the event or the process
	// that produced the event. The exact syntax and semantics behind
	// the data encoded in the URI is defined by the event producer.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// The type of event related to the originating occurrence.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The version of the CloudEvents specification.
	SpecVersion string `protobuf:"bytes,4,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	// The content type of data value.
	DataContentType string `protobuf:"bytes,5,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// The content of the event.
	Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// The pubsub topic which publisher sent to.
	Topic                string   `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TopicEventRequest message is compatiable with CloudEvent spec v1.0 https://github.com/cloudevents/spec/blob/v1.0/spec.md

func (*TopicEventRequest) Descriptor 

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

func (*TopicEventRequest) GetData 

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

func (*TopicEventRequest) GetDataContentType 

func (m *TopicEventRequest) GetDataContentType() string

func (*TopicEventRequest) GetId 

func (m *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetSource 

func (m *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecVersion 

func (m *TopicEventRequest) GetSpecVersion() string

func (*TopicEventRequest) GetTopic 

func (m *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType 

func (m *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage 

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) Reset 

func (m *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (m *TopicEventRequest) String() string

func (*TopicEventRequest) XXX_DiscardUnknown 

func (m *TopicEventRequest) XXX_DiscardUnknown()

func (*TopicEventRequest) XXX_Marshal 

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

func (*TopicEventRequest) XXX_Merge 

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

func (*TopicEventRequest) XXX_Size 

func (m *TopicEventRequest) XXX_Size() int

func (*TopicEventRequest) XXX_Unmarshal 

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

type TopicSubscription 

type TopicSubscription struct {
	// Required. The name of topic which will be subscribed
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The optional properties used for this topic's subscribtion e.g. session id
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

TopicSubscription represents topic and metadata.

func (*TopicSubscription) Descriptor 

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

func (*TopicSubscription) GetMetadata 

func (m *TopicSubscription) GetMetadata() map[string]string

func (*TopicSubscription) GetTopic 

func (m *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) Reset 

func (m *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (m *TopicSubscription) String() string

func (*TopicSubscription) XXX_DiscardUnknown 

func (m *TopicSubscription) XXX_DiscardUnknown()

func (*TopicSubscription) XXX_Marshal 

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

func (*TopicSubscription) XXX_Merge 

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

func (*TopicSubscription) XXX_Size 

func (m *TopicSubscription) XXX_Size() int

func (*TopicSubscription) XXX_Unmarshal 

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

type UnimplementedAppCallbackServer 

type UnimplementedAppCallbackServer struct {
}

UnimplementedAppCallbackServer can be embedded to have forward compatible implementations.

func (*UnimplementedAppCallbackServer) ListInputBindings 

func (*UnimplementedAppCallbackServer) ListInputBindings(ctx context.Context, req *empty.Empty) (*ListInputBindingsResponse, error)

func (*UnimplementedAppCallbackServer) ListTopicSubscriptions 

func (*UnimplementedAppCallbackServer) ListTopicSubscriptions(ctx context.Context, req *empty.Empty) (*ListTopicSubscriptionsResponse, error)

func (*UnimplementedAppCallbackServer) OnBindingEvent 

func (*UnimplementedAppCallbackServer) OnBindingEvent(ctx context.Context, req *BindingEventRequest) (*BindingEventResponse, error)

func (*UnimplementedAppCallbackServer) OnInvoke 

func (*UnimplementedAppCallbackServer) OnInvoke(ctx context.Context, req *v1.InvokeRequest) (*v1.InvokeResponse, error)

func (*UnimplementedAppCallbackServer) OnTopicEvent 

func (*UnimplementedAppCallbackServer) OnTopicEvent(ctx context.Context, req *TopicEventRequest) (*empty.Empty, error)

type UnimplementedDaprServer 

type UnimplementedDaprServer struct {
}

UnimplementedDaprServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaprServer) DeleteState 

func (*UnimplementedDaprServer) DeleteState(ctx context.Context, req *DeleteStateRequest) (*empty.Empty, error)

func (*UnimplementedDaprServer) GetSecret 

func (*UnimplementedDaprServer) GetSecret(ctx context.Context, req *GetSecretRequest) (*GetSecretResponse, error)

func (*UnimplementedDaprServer) GetState 

func (*UnimplementedDaprServer) GetState(ctx context.Context, req *GetStateRequest) (*GetStateResponse, error)

func (*UnimplementedDaprServer) InvokeBinding 

func (*UnimplementedDaprServer) InvokeBinding(ctx context.Context, req *InvokeBindingRequest) (*InvokeBindingResponse, error)

func (*UnimplementedDaprServer) InvokeService 

func (*UnimplementedDaprServer) InvokeService(ctx context.Context, req *InvokeServiceRequest) (*v1.InvokeResponse, error)

func (*UnimplementedDaprServer) PublishEvent 

func (*UnimplementedDaprServer) PublishEvent(ctx context.Context, req *PublishEventRequest) (*empty.Empty, error)

func (*UnimplementedDaprServer) SaveState 

func (*UnimplementedDaprServer) SaveState(ctx context.Context, req *SaveStateRequest) (*empty.Empty, error)

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.