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 RegisterDaprClientServer 

func RegisterDaprClientServer(s *grpc.Server, srv DaprClientServer)

Types

type BindingEventEnvelope 

type BindingEventEnvelope 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 (*BindingEventEnvelope) Descriptor 

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

func (*BindingEventEnvelope) GetData 

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

func (*BindingEventEnvelope) GetMetadata 

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

func (*BindingEventEnvelope) GetName 

func (m *BindingEventEnvelope) GetName() string

func (*BindingEventEnvelope) ProtoMessage 

func (*BindingEventEnvelope) ProtoMessage()

func (*BindingEventEnvelope) Reset 

func (m *BindingEventEnvelope) Reset()

func (*BindingEventEnvelope) String 

func (m *BindingEventEnvelope) String() string

func (*BindingEventEnvelope) XXX_DiscardUnknown 

func (m *BindingEventEnvelope) XXX_DiscardUnknown()

func (*BindingEventEnvelope) XXX_Marshal 

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

func (*BindingEventEnvelope) XXX_Merge 

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

func (*BindingEventEnvelope) XXX_Size 

func (m *BindingEventEnvelope) XXX_Size() int

func (*BindingEventEnvelope) XXX_Unmarshal 

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

type BindingResponseEnvelope 

type BindingResponseEnvelope struct {
	Data                 *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	To                   []string `protobuf:"bytes,2,rep,name=to,proto3" json:"to,omitempty"`
	State                []*State `protobuf:"bytes,3,rep,name=state,proto3" json:"state,omitempty"`
	Concurrency          string   `protobuf:"bytes,4,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BindingResponseEnvelope) Descriptor 

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

func (*BindingResponseEnvelope) GetConcurrency 

func (m *BindingResponseEnvelope) GetConcurrency() string

func (*BindingResponseEnvelope) GetData 

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

func (*BindingResponseEnvelope) GetState 

func (m *BindingResponseEnvelope) GetState() []*State

func (*BindingResponseEnvelope) GetTo 

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

func (*BindingResponseEnvelope) ProtoMessage 

func (*BindingResponseEnvelope) ProtoMessage()

func (*BindingResponseEnvelope) Reset 

func (m *BindingResponseEnvelope) Reset()

func (*BindingResponseEnvelope) String 

func (m *BindingResponseEnvelope) String() string

func (*BindingResponseEnvelope) XXX_DiscardUnknown 

func (m *BindingResponseEnvelope) XXX_DiscardUnknown()

func (*BindingResponseEnvelope) XXX_Marshal 

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

func (*BindingResponseEnvelope) XXX_Merge 

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

func (*BindingResponseEnvelope) XXX_Size 

func (m *BindingResponseEnvelope) XXX_Size() int

func (*BindingResponseEnvelope) XXX_Unmarshal 

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

type CloudEventEnvelope 

type CloudEventEnvelope struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	SpecVersion          string   `protobuf:"bytes,4,opt,name=specVersion,proto3" json:"specVersion,omitempty"`
	DataContentType      string   `protobuf:"bytes,5,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	Topic                string   `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"`
	Data                 *any.Any `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloudEventEnvelope) Descriptor 

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

func (*CloudEventEnvelope) GetData 

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

func (*CloudEventEnvelope) GetDataContentType 

func (m *CloudEventEnvelope) GetDataContentType() string

func (*CloudEventEnvelope) GetId 

func (m *CloudEventEnvelope) GetId() string

func (*CloudEventEnvelope) GetSource 

func (m *CloudEventEnvelope) GetSource() string

func (*CloudEventEnvelope) GetSpecVersion 

func (m *CloudEventEnvelope) GetSpecVersion() string

func (*CloudEventEnvelope) GetTopic 

func (m *CloudEventEnvelope) GetTopic() string

func (*CloudEventEnvelope) GetType 

func (m *CloudEventEnvelope) GetType() string

func (*CloudEventEnvelope) ProtoMessage 

func (*CloudEventEnvelope) ProtoMessage()

func (*CloudEventEnvelope) Reset 

func (m *CloudEventEnvelope) Reset()

func (*CloudEventEnvelope) String 

func (m *CloudEventEnvelope) String() string

func (*CloudEventEnvelope) XXX_DiscardUnknown 

func (m *CloudEventEnvelope) XXX_DiscardUnknown()

func (*CloudEventEnvelope) XXX_Marshal 

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

func (*CloudEventEnvelope) XXX_Merge 

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

func (*CloudEventEnvelope) XXX_Size 

func (m *CloudEventEnvelope) XXX_Size() int

func (*CloudEventEnvelope) XXX_Unmarshal 

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

type DaprClientClient 

type DaprClientClient interface {
	OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	GetTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTopicSubscriptionsEnvelope, error)
	GetBindingsSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetBindingsSubscriptionsEnvelope, error)
	OnBindingEvent(ctx context.Context, in *BindingEventEnvelope, opts ...grpc.CallOption) (*BindingResponseEnvelope, error)
	OnTopicEvent(ctx context.Context, in *CloudEventEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
}

DaprClientClient is the client API for DaprClient service.

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

func NewDaprClientClient 

func NewDaprClientClient(cc *grpc.ClientConn) DaprClientClient

type DaprClientServer 

type DaprClientServer interface {
	OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error)
	GetTopicSubscriptions(context.Context, *empty.Empty) (*GetTopicSubscriptionsEnvelope, error)
	GetBindingsSubscriptions(context.Context, *empty.Empty) (*GetBindingsSubscriptionsEnvelope, error)
	OnBindingEvent(context.Context, *BindingEventEnvelope) (*BindingResponseEnvelope, error)
	OnTopicEvent(context.Context, *CloudEventEnvelope) (*empty.Empty, error)
}

DaprClientServer is the server API for DaprClient service.

type GetBindingsSubscriptionsEnvelope 

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

func (*GetBindingsSubscriptionsEnvelope) Descriptor 

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

func (*GetBindingsSubscriptionsEnvelope) GetBindings 

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

func (*GetBindingsSubscriptionsEnvelope) ProtoMessage 

func (*GetBindingsSubscriptionsEnvelope) ProtoMessage()

func (*GetBindingsSubscriptionsEnvelope) Reset 

func (m *GetBindingsSubscriptionsEnvelope) Reset()

func (*GetBindingsSubscriptionsEnvelope) String 

func (m *GetBindingsSubscriptionsEnvelope) String() string

func (*GetBindingsSubscriptionsEnvelope) XXX_DiscardUnknown 

func (m *GetBindingsSubscriptionsEnvelope) XXX_DiscardUnknown()

func (*GetBindingsSubscriptionsEnvelope) XXX_Marshal 

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

func (*GetBindingsSubscriptionsEnvelope) XXX_Merge 

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

func (*GetBindingsSubscriptionsEnvelope) XXX_Size 

func (m *GetBindingsSubscriptionsEnvelope) XXX_Size() int

func (*GetBindingsSubscriptionsEnvelope) XXX_Unmarshal 

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

type GetTopicSubscriptionsEnvelope 

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

func (*GetTopicSubscriptionsEnvelope) Descriptor 

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

func (*GetTopicSubscriptionsEnvelope) GetTopics 

func (m *GetTopicSubscriptionsEnvelope) GetTopics() []string

func (*GetTopicSubscriptionsEnvelope) ProtoMessage 

func (*GetTopicSubscriptionsEnvelope) ProtoMessage()

func (*GetTopicSubscriptionsEnvelope) Reset 

func (m *GetTopicSubscriptionsEnvelope) Reset()

func (*GetTopicSubscriptionsEnvelope) String 

func (m *GetTopicSubscriptionsEnvelope) String() string

func (*GetTopicSubscriptionsEnvelope) XXX_DiscardUnknown 

func (m *GetTopicSubscriptionsEnvelope) XXX_DiscardUnknown()

func (*GetTopicSubscriptionsEnvelope) XXX_Marshal 

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

func (*GetTopicSubscriptionsEnvelope) XXX_Merge 

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

func (*GetTopicSubscriptionsEnvelope) XXX_Size 

func (m *GetTopicSubscriptionsEnvelope) XXX_Size() int

func (*GetTopicSubscriptionsEnvelope) XXX_Unmarshal 

func (m *GetTopicSubscriptionsEnvelope) 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 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 UnimplementedDaprClientServer 

type UnimplementedDaprClientServer struct {
}

UnimplementedDaprClientServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaprClientServer) GetBindingsSubscriptions 

func (*UnimplementedDaprClientServer) GetBindingsSubscriptions(ctx context.Context, req *empty.Empty) (*GetBindingsSubscriptionsEnvelope, error)

func (*UnimplementedDaprClientServer) GetTopicSubscriptions 

func (*UnimplementedDaprClientServer) GetTopicSubscriptions(ctx context.Context, req *empty.Empty) (*GetTopicSubscriptionsEnvelope, error)

func (*UnimplementedDaprClientServer) OnBindingEvent 

func (*UnimplementedDaprClientServer) OnBindingEvent(ctx context.Context, req *BindingEventEnvelope) (*BindingResponseEnvelope, error)

func (*UnimplementedDaprClientServer) OnInvoke 

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

func (*UnimplementedDaprClientServer) OnTopicEvent 

func (*UnimplementedDaprClientServer) OnTopicEvent(ctx context.Context, req *CloudEventEnvelope) (*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.