v1

package
v0.7.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: May 1, 2020 License: MIT Imports: 4 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,
}

Functions

This section is empty.

Types

type HTTPExtension 

type HTTPExtension struct {
	// verb is HTTP verb.
	//
	// This is required.
	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 {
	// method is a method name which will be invoked by caller.
	//
	// This field is required.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// data conveys bytes value or Protobuf message which caller sent.
	// Dapr treats Any.value as bytes type if Any.type_url is unset.
	//
	// This field is required.
	Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// content_type is 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_extension includes http specific fields if request conveys
	// http-compatible request.
	//
	// 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:"-"`
}

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 {
	// data conveys the content body of InvokeService response.
	//
	// This field is required.
	Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// content_type is the type of data content.
	//
	// This field is required.
	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:"-"`
}

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

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.