common

package
v0.8.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HTTPExtension_Verb_name = map[int32]string{
	0: "NONE",
	1: "GET",
	2: "HEAD",
	3: "POST",
	4: "PUT",
	5: "DELETE",
	6: "CONNECT",
	7: "OPTIONS",
	8: "TRACE",
}
View Source 
var HTTPExtension_Verb_value = map[string]int32{
	"NONE":    0,
	"GET":     1,
	"HEAD":    2,
	"POST":    3,
	"PUT":     4,
	"DELETE":  5,
	"CONNECT": 6,
	"OPTIONS": 7,
	"TRACE":   8,
}
View Source 
var StateOptions_StateConcurrency_name = map[int32]string{
	0: "CONCURRENCY_UNSPECIFIED",
	1: "CONCURRENCY_FIRST_WRITE",
	2: "CONCURRENCY_LAST_WRITE",
}
View Source 
var StateOptions_StateConcurrency_value = map[string]int32{
	"CONCURRENCY_UNSPECIFIED": 0,
	"CONCURRENCY_FIRST_WRITE": 1,
	"CONCURRENCY_LAST_WRITE":  2,
}
View Source 
var StateOptions_StateConsistency_name = map[int32]string{
	0: "CONSISTENCY_UNSPECIFIED",
	1: "CONSISTENCY_EVENTUAL",
	2: "CONSISTENCY_STRONG",
}
View Source 
var StateOptions_StateConsistency_value = map[string]int32{
	"CONSISTENCY_UNSPECIFIED": 0,
	"CONSISTENCY_EVENTUAL":    1,
	"CONSISTENCY_STRONG":      2,
}
View Source 
var StateRetryPolicy_RetryPattern_name = map[int32]string{
	0: "RETRY_UNSPECIFIED",
	1: "RETRY_LINEAR",
	2: "RETRY_EXPONENTIAL",
}
View Source 
var StateRetryPolicy_RetryPattern_value = map[string]int32{
	"RETRY_UNSPECIFIED": 0,
	"RETRY_LINEAR":      1,
	"RETRY_EXPONENTIAL": 2,
}

Functions

This section is empty.

Types

type HTTPExtension 

type HTTPExtension struct {
	// Required. HTTP verb.
	Verb HTTPExtension_Verb `protobuf:"varint,1,opt,name=verb,proto3,enum=dapr.proto.common.v1.HTTPExtension_Verb" json:"verb,omitempty"`
	// querystring includes HTTP querystring.
	Querystring          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

HTTPExtension includes HTTP verb and querystring when Dapr runtime delivers HTTP content.

For example, when callers calls http invoke api POST http://localhost:3500/v1.0/invoke/<app_id>/method/<method>?query1=value1&query2=value2

Dapr runtime will parse POST as a verb and extract querystring to quersytring map.

func (*HTTPExtension) Descriptor 

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

func (*HTTPExtension) GetQuerystring 

func (m *HTTPExtension) GetQuerystring() map[string]string

func (*HTTPExtension) GetVerb 

func (m *HTTPExtension) GetVerb() HTTPExtension_Verb

func (*HTTPExtension) ProtoMessage 

func (*HTTPExtension) ProtoMessage()

func (*HTTPExtension) Reset 

func (m *HTTPExtension) Reset()

func (*HTTPExtension) String 

func (m *HTTPExtension) String() string

func (*HTTPExtension) XXX_DiscardUnknown 

func (m *HTTPExtension) XXX_DiscardUnknown()

func (*HTTPExtension) XXX_Marshal 

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

func (*HTTPExtension) XXX_Merge 

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

func (*HTTPExtension) XXX_Size 

func (m *HTTPExtension) XXX_Size() int

func (*HTTPExtension) XXX_Unmarshal 

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

type HTTPExtension_Verb 

type HTTPExtension_Verb int32

Type of HTTP 1.1 Methods RFC 7231: https://tools.ietf.org/html/rfc7231#page-24 

const (
	HTTPExtension_NONE    HTTPExtension_Verb = 0
	HTTPExtension_GET     HTTPExtension_Verb = 1
	HTTPExtension_HEAD    HTTPExtension_Verb = 2
	HTTPExtension_POST    HTTPExtension_Verb = 3
	HTTPExtension_PUT     HTTPExtension_Verb = 4
	HTTPExtension_DELETE  HTTPExtension_Verb = 5
	HTTPExtension_CONNECT HTTPExtension_Verb = 6
	HTTPExtension_OPTIONS HTTPExtension_Verb = 7
	HTTPExtension_TRACE   HTTPExtension_Verb = 8
)

func (HTTPExtension_Verb) EnumDescriptor 

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

func (HTTPExtension_Verb) String 

func (x HTTPExtension_Verb) String() string

type InvokeRequest 

type InvokeRequest struct {
	// Required. method is a method name which will be invoked by caller.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// Required. Bytes value or Protobuf message which caller sent.
	// Dapr treats Any.value as bytes type if Any.type_url is unset.
	Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The type of data content.
	//
	// This field is required if data delivers http request body
	// Otherwise, this is optional.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// HTTP specific fields if request conveys http-compatible request.
	//
	// This field is required for http-compatible request. Otherwise,
	// this field is optional.
	HttpExtension        *HTTPExtension `protobuf:"bytes,4,opt,name=http_extension,json=httpExtension,proto3" json:"http_extension,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

InvokeRequest is the message to invoke a method with the data. This message is used in InvokeService of Dapr gRPC Service and OnInvoke of AppCallback gRPC service.

func (*InvokeRequest) Descriptor 

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

func (*InvokeRequest) GetContentType 

func (m *InvokeRequest) GetContentType() string

func (*InvokeRequest) GetData 

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

func (*InvokeRequest) GetHttpExtension 

func (m *InvokeRequest) GetHttpExtension() *HTTPExtension

func (*InvokeRequest) GetMethod 

func (m *InvokeRequest) GetMethod() string

func (*InvokeRequest) ProtoMessage 

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) Reset 

func (m *InvokeRequest) Reset()

func (*InvokeRequest) String 

func (m *InvokeRequest) String() string

func (*InvokeRequest) XXX_DiscardUnknown 

func (m *InvokeRequest) XXX_DiscardUnknown()

func (*InvokeRequest) XXX_Marshal 

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

func (*InvokeRequest) XXX_Merge 

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

func (*InvokeRequest) XXX_Size 

func (m *InvokeRequest) XXX_Size() int

func (*InvokeRequest) XXX_Unmarshal 

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

type InvokeResponse 

type InvokeResponse struct {
	// Required. The content body of InvokeService response.
	Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Required. The type of data content.
	ContentType          string   `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InvokeResponse is the response message inclduing data and its content type from app callback. This message is used in InvokeService of Dapr gRPC Service and OnInvoke of AppCallback gRPC service.

func (*InvokeResponse) Descriptor 

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

func (*InvokeResponse) GetContentType 

func (m *InvokeResponse) GetContentType() string

func (*InvokeResponse) GetData 

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

func (*InvokeResponse) ProtoMessage 

func (*InvokeResponse) ProtoMessage()

func (*InvokeResponse) Reset 

func (m *InvokeResponse) Reset()

func (*InvokeResponse) String 

func (m *InvokeResponse) String() string

func (*InvokeResponse) XXX_DiscardUnknown 

func (m *InvokeResponse) XXX_DiscardUnknown()

func (*InvokeResponse) XXX_Marshal 

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

func (*InvokeResponse) XXX_Merge 

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

func (*InvokeResponse) XXX_Size 

func (m *InvokeResponse) XXX_Size() int

func (*InvokeResponse) XXX_Unmarshal 

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

type StateItem added in v0.8.0 

type StateItem struct {
	// Required. The state key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Required. The state data for key
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,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"`
	// The metadata which will be passed to state store component.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Options for concurrency, consistency, and retry_policy to save the state.
	Options              *StateOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

StateItem represents state key, value, and additional options to save state.

func (*StateItem) Descriptor added in v0.8.0 

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

func (*StateItem) GetEtag added in v0.8.0 

func (m *StateItem) GetEtag() string

func (*StateItem) GetKey added in v0.8.0 

func (m *StateItem) GetKey() string

func (*StateItem) GetMetadata added in v0.8.0 

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

func (*StateItem) GetOptions added in v0.8.0 

func (m *StateItem) GetOptions() *StateOptions

func (*StateItem) GetValue added in v0.8.0 

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

func (*StateItem) ProtoMessage added in v0.8.0 

func (*StateItem) ProtoMessage()

func (*StateItem) Reset added in v0.8.0 

func (m *StateItem) Reset()

func (*StateItem) String added in v0.8.0 

func (m *StateItem) String() string

func (*StateItem) XXX_DiscardUnknown added in v0.8.0 

func (m *StateItem) XXX_DiscardUnknown()

func (*StateItem) XXX_Marshal added in v0.8.0 

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

func (*StateItem) XXX_Merge added in v0.8.0 

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

func (*StateItem) XXX_Size added in v0.8.0 

func (m *StateItem) XXX_Size() int

func (*StateItem) XXX_Unmarshal added in v0.8.0 

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

type StateOptions added in v0.8.0 

type StateOptions struct {
	Concurrency          StateOptions_StateConcurrency `` /* 132-byte string literal not displayed */
	Consistency          StateOptions_StateConsistency `` /* 132-byte string literal not displayed */
	RetryPolicy          *StateRetryPolicy             `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:"-"`
}

StateOptions configures concurrency, consistency, and retry policy for state operations

func (*StateOptions) Descriptor added in v0.8.0 

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

func (*StateOptions) GetConcurrency added in v0.8.0 

func (m *StateOptions) GetConcurrency() StateOptions_StateConcurrency

func (*StateOptions) GetConsistency added in v0.8.0 

func (m *StateOptions) GetConsistency() StateOptions_StateConsistency

func (*StateOptions) GetRetryPolicy added in v0.8.0 

func (m *StateOptions) GetRetryPolicy() *StateRetryPolicy

func (*StateOptions) ProtoMessage added in v0.8.0 

func (*StateOptions) ProtoMessage()

func (*StateOptions) Reset added in v0.8.0 

func (m *StateOptions) Reset()

func (*StateOptions) String added in v0.8.0 

func (m *StateOptions) String() string

func (*StateOptions) XXX_DiscardUnknown added in v0.8.0 

func (m *StateOptions) XXX_DiscardUnknown()

func (*StateOptions) XXX_Marshal added in v0.8.0 

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

func (*StateOptions) XXX_Merge added in v0.8.0 

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

func (*StateOptions) XXX_Size added in v0.8.0 

func (m *StateOptions) XXX_Size() int

func (*StateOptions) XXX_Unmarshal added in v0.8.0 

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

type StateOptions_StateConcurrency added in v0.8.0 

type StateOptions_StateConcurrency int32

Enum describing the supported concurrency for state. 

const (
	StateOptions_CONCURRENCY_UNSPECIFIED StateOptions_StateConcurrency = 0
	StateOptions_CONCURRENCY_FIRST_WRITE StateOptions_StateConcurrency = 1
	StateOptions_CONCURRENCY_LAST_WRITE  StateOptions_StateConcurrency = 2
)

func (StateOptions_StateConcurrency) EnumDescriptor added in v0.8.0 

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

func (StateOptions_StateConcurrency) String added in v0.8.0 

func (x StateOptions_StateConcurrency) String() string

type StateOptions_StateConsistency added in v0.8.0 

type StateOptions_StateConsistency int32

Enum describing the supported consistency for state. 

const (
	StateOptions_CONSISTENCY_UNSPECIFIED StateOptions_StateConsistency = 0
	StateOptions_CONSISTENCY_EVENTUAL    StateOptions_StateConsistency = 1
	StateOptions_CONSISTENCY_STRONG      StateOptions_StateConsistency = 2
)

func (StateOptions_StateConsistency) EnumDescriptor added in v0.8.0 

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

func (StateOptions_StateConsistency) String added in v0.8.0 

func (x StateOptions_StateConsistency) String() string

type StateRetryPolicy added in v0.8.0 

type StateRetryPolicy struct {
	// Maximum number of retries.
	Threshold int32 `protobuf:"varint,1,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// Retry pattern.
	Pattern StateRetryPolicy_RetryPattern `protobuf:"varint,2,opt,name=pattern,proto3,enum=dapr.proto.common.v1.StateRetryPolicy_RetryPattern" json:"pattern,omitempty"`
	// Initial delay between retries.
	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:"-"`
}

StateRetryPolicy represents retry policy to set and delete state operations.

func (*StateRetryPolicy) Descriptor added in v0.8.0 

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

func (*StateRetryPolicy) GetInterval added in v0.8.0 

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

func (*StateRetryPolicy) GetPattern added in v0.8.0 

func (m *StateRetryPolicy) GetPattern() StateRetryPolicy_RetryPattern

func (*StateRetryPolicy) GetThreshold added in v0.8.0 

func (m *StateRetryPolicy) GetThreshold() int32

func (*StateRetryPolicy) ProtoMessage added in v0.8.0 

func (*StateRetryPolicy) ProtoMessage()

func (*StateRetryPolicy) Reset added in v0.8.0 

func (m *StateRetryPolicy) Reset()

func (*StateRetryPolicy) String added in v0.8.0 

func (m *StateRetryPolicy) String() string

func (*StateRetryPolicy) XXX_DiscardUnknown added in v0.8.0 

func (m *StateRetryPolicy) XXX_DiscardUnknown()

func (*StateRetryPolicy) XXX_Marshal added in v0.8.0 

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

func (*StateRetryPolicy) XXX_Merge added in v0.8.0 

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

func (*StateRetryPolicy) XXX_Size added in v0.8.0 

func (m *StateRetryPolicy) XXX_Size() int

func (*StateRetryPolicy) XXX_Unmarshal added in v0.8.0 

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

type StateRetryPolicy_RetryPattern added in v0.8.0 

type StateRetryPolicy_RetryPattern int32

Enum describing the support retry pattern 

const (
	StateRetryPolicy_RETRY_UNSPECIFIED StateRetryPolicy_RetryPattern = 0
	StateRetryPolicy_RETRY_LINEAR      StateRetryPolicy_RetryPattern = 1
	StateRetryPolicy_RETRY_EXPONENTIAL StateRetryPolicy_RetryPattern = 2
)

func (StateRetryPolicy_RetryPattern) EnumDescriptor added in v0.8.0 

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

func (StateRetryPolicy_RetryPattern) String added in v0.8.0 

func (x StateRetryPolicy_RetryPattern) String() string

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.