v1

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: May 12, 2020 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDaprServer 

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

Types

type DaprClient 

type DaprClient interface {
	PublishEvent(ctx context.Context, in *PublishEventEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	InvokeBinding(ctx context.Context, in *InvokeBindingEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
	GetState(ctx context.Context, in *GetStateEnvelope, opts ...grpc.CallOption) (*GetStateResponseEnvelope, error)
	GetSecret(ctx context.Context, in *GetSecretEnvelope, opts ...grpc.CallOption) (*GetSecretResponseEnvelope, error)
	SaveState(ctx context.Context, in *SaveStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteState(ctx context.Context, in *DeleteStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, 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 {
	PublishEvent(context.Context, *PublishEventEnvelope) (*empty.Empty, error)
	InvokeService(context.Context, *InvokeServiceRequest) (*v1.InvokeResponse, error)
	InvokeBinding(context.Context, *InvokeBindingEnvelope) (*empty.Empty, error)
	GetState(context.Context, *GetStateEnvelope) (*GetStateResponseEnvelope, error)
	GetSecret(context.Context, *GetSecretEnvelope) (*GetSecretResponseEnvelope, error)
	SaveState(context.Context, *SaveStateEnvelope) (*empty.Empty, error)
	DeleteState(context.Context, *DeleteStateEnvelope) (*empty.Empty, error)
}

DaprServer is the server API for Dapr service.

type DeleteStateEnvelope 

type DeleteStateEnvelope struct {
	StoreName            string        `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	Key                  string        `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Etag                 string        `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	Options              *StateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DeleteStateEnvelope) Descriptor 

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

func (*DeleteStateEnvelope) GetEtag 

func (m *DeleteStateEnvelope) GetEtag() string

func (*DeleteStateEnvelope) GetKey 

func (m *DeleteStateEnvelope) GetKey() string

func (*DeleteStateEnvelope) GetOptions 

func (m *DeleteStateEnvelope) GetOptions() *StateOptions

func (*DeleteStateEnvelope) GetStoreName 

func (m *DeleteStateEnvelope) GetStoreName() string

func (*DeleteStateEnvelope) ProtoMessage 

func (*DeleteStateEnvelope) ProtoMessage()

func (*DeleteStateEnvelope) Reset 

func (m *DeleteStateEnvelope) Reset()

func (*DeleteStateEnvelope) String 

func (m *DeleteStateEnvelope) String() string

func (*DeleteStateEnvelope) XXX_DiscardUnknown 

func (m *DeleteStateEnvelope) XXX_DiscardUnknown()

func (*DeleteStateEnvelope) XXX_Marshal 

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

func (*DeleteStateEnvelope) XXX_Merge 

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

func (*DeleteStateEnvelope) XXX_Size 

func (m *DeleteStateEnvelope) XXX_Size() int

func (*DeleteStateEnvelope) XXX_Unmarshal 

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

type GetSecretEnvelope 

type GetSecretEnvelope struct {
	StoreName            string            `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	Key                  string            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetSecretEnvelope) Descriptor 

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

func (*GetSecretEnvelope) GetKey 

func (m *GetSecretEnvelope) GetKey() string

func (*GetSecretEnvelope) GetMetadata 

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

func (*GetSecretEnvelope) GetStoreName 

func (m *GetSecretEnvelope) GetStoreName() string

func (*GetSecretEnvelope) ProtoMessage 

func (*GetSecretEnvelope) ProtoMessage()

func (*GetSecretEnvelope) Reset 

func (m *GetSecretEnvelope) Reset()

func (*GetSecretEnvelope) String 

func (m *GetSecretEnvelope) String() string

func (*GetSecretEnvelope) XXX_DiscardUnknown 

func (m *GetSecretEnvelope) XXX_DiscardUnknown()

func (*GetSecretEnvelope) XXX_Marshal 

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

func (*GetSecretEnvelope) XXX_Merge 

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

func (*GetSecretEnvelope) XXX_Size 

func (m *GetSecretEnvelope) XXX_Size() int

func (*GetSecretEnvelope) XXX_Unmarshal 

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

type GetSecretResponseEnvelope 

type GetSecretResponseEnvelope struct {
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetSecretResponseEnvelope) Descriptor 

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

func (*GetSecretResponseEnvelope) GetData 

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

func (*GetSecretResponseEnvelope) ProtoMessage 

func (*GetSecretResponseEnvelope) ProtoMessage()

func (*GetSecretResponseEnvelope) Reset 

func (m *GetSecretResponseEnvelope) Reset()

func (*GetSecretResponseEnvelope) String 

func (m *GetSecretResponseEnvelope) String() string

func (*GetSecretResponseEnvelope) XXX_DiscardUnknown 

func (m *GetSecretResponseEnvelope) XXX_DiscardUnknown()

func (*GetSecretResponseEnvelope) XXX_Marshal 

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

func (*GetSecretResponseEnvelope) XXX_Merge 

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

func (*GetSecretResponseEnvelope) XXX_Size 

func (m *GetSecretResponseEnvelope) XXX_Size() int

func (*GetSecretResponseEnvelope) XXX_Unmarshal 

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

type GetStateEnvelope 

type GetStateEnvelope struct {
	StoreName            string   `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Consistency          string   `protobuf:"bytes,3,opt,name=consistency,proto3" json:"consistency,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateEnvelope) Descriptor 

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

func (*GetStateEnvelope) GetConsistency 

func (m *GetStateEnvelope) GetConsistency() string

func (*GetStateEnvelope) GetKey 

func (m *GetStateEnvelope) GetKey() string

func (*GetStateEnvelope) GetStoreName 

func (m *GetStateEnvelope) GetStoreName() string

func (*GetStateEnvelope) ProtoMessage 

func (*GetStateEnvelope) ProtoMessage()

func (*GetStateEnvelope) Reset 

func (m *GetStateEnvelope) Reset()

func (*GetStateEnvelope) String 

func (m *GetStateEnvelope) String() string

func (*GetStateEnvelope) XXX_DiscardUnknown 

func (m *GetStateEnvelope) XXX_DiscardUnknown()

func (*GetStateEnvelope) XXX_Marshal 

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

func (*GetStateEnvelope) XXX_Merge 

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

func (*GetStateEnvelope) XXX_Size 

func (m *GetStateEnvelope) XXX_Size() int

func (*GetStateEnvelope) XXX_Unmarshal 

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

type GetStateResponseEnvelope 

type GetStateResponseEnvelope struct {
	Data                 *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Etag                 string   `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateResponseEnvelope) Descriptor 

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

func (*GetStateResponseEnvelope) GetData 

func (m *GetStateResponseEnvelope) GetData() *any.Any

func (*GetStateResponseEnvelope) GetEtag 

func (m *GetStateResponseEnvelope) GetEtag() string

func (*GetStateResponseEnvelope) ProtoMessage 

func (*GetStateResponseEnvelope) ProtoMessage()

func (*GetStateResponseEnvelope) Reset 

func (m *GetStateResponseEnvelope) Reset()

func (*GetStateResponseEnvelope) String 

func (m *GetStateResponseEnvelope) String() string

func (*GetStateResponseEnvelope) XXX_DiscardUnknown 

func (m *GetStateResponseEnvelope) XXX_DiscardUnknown()

func (*GetStateResponseEnvelope) XXX_Marshal 

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

func (*GetStateResponseEnvelope) XXX_Merge 

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

func (*GetStateResponseEnvelope) XXX_Size 

func (m *GetStateResponseEnvelope) XXX_Size() int

func (*GetStateResponseEnvelope) XXX_Unmarshal 

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

type InvokeBindingEnvelope 

type InvokeBindingEnvelope struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data                 *any.Any          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*InvokeBindingEnvelope) Descriptor 

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

func (*InvokeBindingEnvelope) GetData 

func (m *InvokeBindingEnvelope) GetData() *any.Any

func (*InvokeBindingEnvelope) GetMetadata 

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

func (*InvokeBindingEnvelope) GetName 

func (m *InvokeBindingEnvelope) GetName() string

func (*InvokeBindingEnvelope) ProtoMessage 

func (*InvokeBindingEnvelope) ProtoMessage()

func (*InvokeBindingEnvelope) Reset 

func (m *InvokeBindingEnvelope) Reset()

func (*InvokeBindingEnvelope) String 

func (m *InvokeBindingEnvelope) String() string

func (*InvokeBindingEnvelope) XXX_DiscardUnknown 

func (m *InvokeBindingEnvelope) XXX_DiscardUnknown()

func (*InvokeBindingEnvelope) XXX_Marshal 

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

func (*InvokeBindingEnvelope) XXX_Merge 

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

func (*InvokeBindingEnvelope) XXX_Size 

func (m *InvokeBindingEnvelope) XXX_Size() int

func (*InvokeBindingEnvelope) XXX_Unmarshal 

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

type InvokeServiceRequest 

type InvokeServiceRequest struct {
	// id specifies callee's app id.
	//
	// This field is required.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// message which will be delivered to callee.
	//
	// This field is required.
	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 PublishEventEnvelope 

type PublishEventEnvelope struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Data                 *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishEventEnvelope) Descriptor 

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

func (*PublishEventEnvelope) GetData 

func (m *PublishEventEnvelope) GetData() *any.Any

func (*PublishEventEnvelope) GetTopic 

func (m *PublishEventEnvelope) GetTopic() string

func (*PublishEventEnvelope) ProtoMessage 

func (*PublishEventEnvelope) ProtoMessage()

func (*PublishEventEnvelope) Reset 

func (m *PublishEventEnvelope) Reset()

func (*PublishEventEnvelope) String 

func (m *PublishEventEnvelope) String() string

func (*PublishEventEnvelope) XXX_DiscardUnknown 

func (m *PublishEventEnvelope) XXX_DiscardUnknown()

func (*PublishEventEnvelope) XXX_Marshal 

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

func (*PublishEventEnvelope) XXX_Merge 

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

func (*PublishEventEnvelope) XXX_Size 

func (m *PublishEventEnvelope) XXX_Size() int

func (*PublishEventEnvelope) XXX_Unmarshal 

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

type RetryPolicy 

type RetryPolicy struct {
	Threshold            int32              `protobuf:"varint,1,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Pattern              string             `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Interval             *duration.Duration `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RetryPolicy) Descriptor 

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

func (*RetryPolicy) GetInterval 

func (m *RetryPolicy) GetInterval() *duration.Duration

func (*RetryPolicy) GetPattern 

func (m *RetryPolicy) GetPattern() string

func (*RetryPolicy) GetThreshold 

func (m *RetryPolicy) GetThreshold() int32

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) Reset 

func (m *RetryPolicy) Reset()

func (*RetryPolicy) String 

func (m *RetryPolicy) String() string

func (*RetryPolicy) XXX_DiscardUnknown 

func (m *RetryPolicy) XXX_DiscardUnknown()

func (*RetryPolicy) XXX_Marshal 

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

func (*RetryPolicy) XXX_Merge 

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

func (*RetryPolicy) XXX_Size 

func (m *RetryPolicy) XXX_Size() int

func (*RetryPolicy) XXX_Unmarshal 

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

type SaveStateEnvelope 

type SaveStateEnvelope struct {
	StoreName            string          `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	Requests             []*StateRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SaveStateEnvelope) Descriptor 

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

func (*SaveStateEnvelope) GetRequests 

func (m *SaveStateEnvelope) GetRequests() []*StateRequest

func (*SaveStateEnvelope) GetStoreName 

func (m *SaveStateEnvelope) GetStoreName() string

func (*SaveStateEnvelope) ProtoMessage 

func (*SaveStateEnvelope) ProtoMessage()

func (*SaveStateEnvelope) Reset 

func (m *SaveStateEnvelope) Reset()

func (*SaveStateEnvelope) String 

func (m *SaveStateEnvelope) String() string

func (*SaveStateEnvelope) XXX_DiscardUnknown 

func (m *SaveStateEnvelope) XXX_DiscardUnknown()

func (*SaveStateEnvelope) XXX_Marshal 

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

func (*SaveStateEnvelope) XXX_Merge 

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

func (*SaveStateEnvelope) XXX_Size 

func (m *SaveStateEnvelope) XXX_Size() int

func (*SaveStateEnvelope) XXX_Unmarshal 

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

type State 

type State struct {
	Key                  string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Etag                 string            `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Options              *StateOptions     `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*State) Descriptor 

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

func (*State) GetEtag 

func (m *State) GetEtag() string

func (*State) GetKey 

func (m *State) GetKey() string

func (*State) GetMetadata 

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

func (*State) GetOptions 

func (m *State) GetOptions() *StateOptions

func (*State) GetValue 

func (m *State) GetValue() *any.Any

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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

type StateOptions 

type StateOptions struct {
	Concurrency          string       `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Consistency          string       `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
	RetryPolicy          *RetryPolicy `protobuf:"bytes,3,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StateOptions) Descriptor 

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

func (*StateOptions) GetConcurrency 

func (m *StateOptions) GetConcurrency() string

func (*StateOptions) GetConsistency 

func (m *StateOptions) GetConsistency() string

func (*StateOptions) GetRetryPolicy 

func (m *StateOptions) GetRetryPolicy() *RetryPolicy

func (*StateOptions) ProtoMessage 

func (*StateOptions) ProtoMessage()

func (*StateOptions) Reset 

func (m *StateOptions) Reset()

func (*StateOptions) String 

func (m *StateOptions) String() string

func (*StateOptions) XXX_DiscardUnknown 

func (m *StateOptions) XXX_DiscardUnknown()

func (*StateOptions) XXX_Marshal 

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

func (*StateOptions) XXX_Merge 

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

func (*StateOptions) XXX_Size 

func (m *StateOptions) XXX_Size() int

func (*StateOptions) XXX_Unmarshal 

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

type StateRequest 

type StateRequest struct {
	Key                  string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Etag                 string            `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Options              *StateOptions     `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StateRequest) Descriptor 

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

func (*StateRequest) GetEtag 

func (m *StateRequest) GetEtag() string

func (*StateRequest) GetKey 

func (m *StateRequest) GetKey() string

func (*StateRequest) GetMetadata 

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

func (*StateRequest) GetOptions 

func (m *StateRequest) GetOptions() *StateOptions

func (*StateRequest) GetValue 

func (m *StateRequest) GetValue() *any.Any

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) Reset 

func (m *StateRequest) Reset()

func (*StateRequest) String 

func (m *StateRequest) String() string

func (*StateRequest) XXX_DiscardUnknown 

func (m *StateRequest) XXX_DiscardUnknown()

func (*StateRequest) XXX_Marshal 

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

func (*StateRequest) XXX_Merge 

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

func (*StateRequest) XXX_Size 

func (m *StateRequest) XXX_Size() int

func (*StateRequest) XXX_Unmarshal 

func (m *StateRequest) XXX_Unmarshal(b []byte) 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 *DeleteStateEnvelope) (*empty.Empty, error)

func (*UnimplementedDaprServer) GetSecret 

func (*UnimplementedDaprServer) GetSecret(ctx context.Context, req *GetSecretEnvelope) (*GetSecretResponseEnvelope, error)

func (*UnimplementedDaprServer) GetState 

func (*UnimplementedDaprServer) GetState(ctx context.Context, req *GetStateEnvelope) (*GetStateResponseEnvelope, error)

func (*UnimplementedDaprServer) InvokeBinding 

func (*UnimplementedDaprServer) InvokeBinding(ctx context.Context, req *InvokeBindingEnvelope) (*empty.Empty, 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 *PublishEventEnvelope) (*empty.Empty, error)

func (*UnimplementedDaprServer) SaveState 

func (*UnimplementedDaprServer) SaveState(ctx context.Context, req *SaveStateEnvelope) (*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.