Documentation ¶
Index ¶
- Variables
- type AddressCommandSet
- func (*AddressCommandSet) Descriptor() ([]byte, []int)
- func (m *AddressCommandSet) GetAddress() string
- func (m *AddressCommandSet) GetCommmands() []string
- func (*AddressCommandSet) ProtoMessage()
- func (m *AddressCommandSet) Reset()
- func (m *AddressCommandSet) String() string
- func (m *AddressCommandSet) XXX_DiscardUnknown()
- func (m *AddressCommandSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AddressCommandSet) XXX_Merge(src proto.Message)
- func (m *AddressCommandSet) XXX_Size() int
- func (m *AddressCommandSet) XXX_Unmarshal(b []byte) error
- type ConnectionConfig
- func (*ConnectionConfig) Descriptor() ([]byte, []int)
- func (m *ConnectionConfig) GetClearPeriod() uint32
- func (m *ConnectionConfig) GetIdleConnTimeout() uint32
- func (m *ConnectionConfig) GetMaxConns() uint32
- func (m *ConnectionConfig) GetMinConns() uint32
- func (m *ConnectionConfig) GetWaitConnTimeout() uint32
- func (*ConnectionConfig) ProtoMessage()
- func (m *ConnectionConfig) Reset()
- func (m *ConnectionConfig) String() string
- func (m *ConnectionConfig) XXX_DiscardUnknown()
- func (m *ConnectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConnectionConfig) XXX_Merge(src proto.Message)
- func (m *ConnectionConfig) XXX_Size() int
- func (m *ConnectionConfig) XXX_Unmarshal(b []byte) error
- type Constant
- func (*Constant) Descriptor() ([]byte, []int)
- func (*Constant) ProtoMessage()
- func (m *Constant) Reset()
- func (m *Constant) String() string
- func (m *Constant) XXX_DiscardUnknown()
- func (m *Constant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Constant) XXX_Merge(src proto.Message)
- func (m *Constant) XXX_Size() int
- func (m *Constant) XXX_Unmarshal(b []byte) error
- type Constant_ContentType
- type Constant_HttpMethod
- type ErrorResponse
- func (*ErrorResponse) Descriptor() ([]byte, []int)
- func (m *ErrorResponse) GetDebugMessage() string
- func (*ErrorResponse) ProtoMessage()
- func (m *ErrorResponse) Reset()
- func (m *ErrorResponse) String() string
- func (m *ErrorResponse) XXX_DiscardUnknown()
- func (m *ErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ErrorResponse) XXX_Merge(src proto.Message)
- func (m *ErrorResponse) XXX_Size() int
- func (m *ErrorResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequest) GetAddress() string
- func (*HealthCheckRequest) ProtoMessage()
- func (m *HealthCheckRequest) Reset()
- func (m *HealthCheckRequest) String() string
- func (m *HealthCheckRequest) XXX_DiscardUnknown()
- func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HealthCheckRequest) XXX_Merge(src proto.Message)
- func (m *HealthCheckRequest) XXX_Size() int
- func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)
- func (m *HealthCheckResponse) GetDebugMessage() string
- func (*HealthCheckResponse) ProtoMessage()
- func (m *HealthCheckResponse) Reset()
- func (m *HealthCheckResponse) String() string
- func (m *HealthCheckResponse) XXX_DiscardUnknown()
- func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HealthCheckResponse) XXX_Merge(src proto.Message)
- func (m *HealthCheckResponse) XXX_Size() int
- func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error
- type HttpConfig
- func (*HttpConfig) Descriptor() ([]byte, []int)
- func (m *HttpConfig) GetMethod() Constant_HttpMethod
- func (m *HttpConfig) GetPath() string
- func (*HttpConfig) ProtoMessage()
- func (m *HttpConfig) Reset()
- func (m *HttpConfig) String() string
- func (m *HttpConfig) XXX_DiscardUnknown()
- func (m *HttpConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HttpConfig) XXX_Merge(src proto.Message)
- func (m *HttpConfig) XXX_Size() int
- func (m *HttpConfig) XXX_Unmarshal(b []byte) error
- type ProcessorRegistry
- func (*ProcessorRegistry) Descriptor() ([]byte, []int)
- func (m *ProcessorRegistry) GetCommand() string
- func (m *ProcessorRegistry) GetHttpConfig() *HttpConfig
- func (*ProcessorRegistry) ProtoMessage()
- func (m *ProcessorRegistry) Reset()
- func (m *ProcessorRegistry) String() string
- func (m *ProcessorRegistry) XXX_DiscardUnknown()
- func (m *ProcessorRegistry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProcessorRegistry) XXX_Merge(src proto.Message)
- func (m *ProcessorRegistry) XXX_Size() int
- func (m *ProcessorRegistry) XXX_Unmarshal(b []byte) error
- type RegisterServiceRequest
- func (*RegisterServiceRequest) Descriptor() ([]byte, []int)
- func (m *RegisterServiceRequest) GetAccessKey() string
- func (m *RegisterServiceRequest) GetAddresses() []string
- func (m *RegisterServiceRequest) GetConnConfig() *ConnectionConfig
- func (m *RegisterServiceRequest) GetProcessorRegistries() []*ProcessorRegistry
- func (*RegisterServiceRequest) ProtoMessage()
- func (m *RegisterServiceRequest) Reset()
- func (m *RegisterServiceRequest) String() string
- func (m *RegisterServiceRequest) XXX_DiscardUnknown()
- func (m *RegisterServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RegisterServiceRequest) XXX_Merge(src proto.Message)
- func (m *RegisterServiceRequest) XXX_Size() int
- func (m *RegisterServiceRequest) XXX_Unmarshal(b []byte) error
- type RegisterServiceResponse
- func (*RegisterServiceResponse) Descriptor() ([]byte, []int)
- func (m *RegisterServiceResponse) GetAddress() string
- func (*RegisterServiceResponse) ProtoMessage()
- func (m *RegisterServiceResponse) Reset()
- func (m *RegisterServiceResponse) String() string
- func (m *RegisterServiceResponse) XXX_DiscardUnknown()
- func (m *RegisterServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RegisterServiceResponse) XXX_Merge(src proto.Message)
- func (m *RegisterServiceResponse) XXX_Size() int
- func (m *RegisterServiceResponse) XXX_Unmarshal(b []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetBody() []byte
- func (m *Request) GetCommand() string
- func (m *Request) GetContentType() Constant_ContentType
- func (m *Request) GetHeader() map[string]string
- func (m *Request) GetHttpAddress() string
- func (m *Request) GetIsProto() bool
- func (m *Request) GetLogId() string
- func (m *Request) GetQuery() map[string]string
- func (m *Request) GetRawContentType() string
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) String() string
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetBody() []byte
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type UpdateRegistriesRequest
- func (*UpdateRegistriesRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRegistriesRequest) GetAddressCommands() []*AddressCommandSet
- func (*UpdateRegistriesRequest) ProtoMessage()
- func (m *UpdateRegistriesRequest) Reset()
- func (m *UpdateRegistriesRequest) String() string
- func (m *UpdateRegistriesRequest) XXX_DiscardUnknown()
- func (m *UpdateRegistriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UpdateRegistriesRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRegistriesRequest) XXX_Size() int
- func (m *UpdateRegistriesRequest) XXX_Unmarshal(b []byte) error
- type UpdateRegistriesResponse
- func (*UpdateRegistriesResponse) Descriptor() ([]byte, []int)
- func (m *UpdateRegistriesResponse) GetDebugMessage() string
- func (*UpdateRegistriesResponse) ProtoMessage()
- func (m *UpdateRegistriesResponse) Reset()
- func (m *UpdateRegistriesResponse) String() string
- func (m *UpdateRegistriesResponse) XXX_DiscardUnknown()
- func (m *UpdateRegistriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UpdateRegistriesResponse) XXX_Merge(src proto.Message)
- func (m *UpdateRegistriesResponse) XXX_Size() int
- func (m *UpdateRegistriesResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Constant_ContentType_name = map[int32]string{
0: "CONTENT_TYPE_UNKNOWN",
1: "CONTENT_TYPE_JSON",
2: "CONTENT_TYPE_FORM_DATA",
3: "CONTENT_TYPE_X_WWW_FORM_URLENCODED",
}
View Source
var Constant_ContentType_value = map[string]int32{
"CONTENT_TYPE_UNKNOWN": 0,
"CONTENT_TYPE_JSON": 1,
"CONTENT_TYPE_FORM_DATA": 2,
"CONTENT_TYPE_X_WWW_FORM_URLENCODED": 3,
}
View Source
var Constant_HttpMethod_name = map[int32]string{
0: "HTTP_METHOD_UNKNOWN",
1: "HTTP_METHOD_GET",
2: "HTTP_METHOD_POST",
}
View Source
var Constant_HttpMethod_value = map[string]int32{
"HTTP_METHOD_UNKNOWN": 0,
"HTTP_METHOD_GET": 1,
"HTTP_METHOD_POST": 2,
}
Functions ¶
This section is empty.
Types ¶
type AddressCommandSet ¶ added in v1.0.0
type AddressCommandSet struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Commmands []string `protobuf:"bytes,2,rep,name=commmands,proto3" json:"commmands,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AddressCommandSet) Descriptor ¶ added in v1.0.0
func (*AddressCommandSet) Descriptor() ([]byte, []int)
func (*AddressCommandSet) GetAddress ¶ added in v1.0.0
func (m *AddressCommandSet) GetAddress() string
func (*AddressCommandSet) GetCommmands ¶ added in v1.0.0
func (m *AddressCommandSet) GetCommmands() []string
func (*AddressCommandSet) ProtoMessage ¶ added in v1.0.0
func (*AddressCommandSet) ProtoMessage()
func (*AddressCommandSet) Reset ¶ added in v1.0.0
func (m *AddressCommandSet) Reset()
func (*AddressCommandSet) String ¶ added in v1.0.0
func (m *AddressCommandSet) String() string
func (*AddressCommandSet) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *AddressCommandSet) XXX_DiscardUnknown()
func (*AddressCommandSet) XXX_Marshal ¶ added in v1.0.0
func (m *AddressCommandSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddressCommandSet) XXX_Merge ¶ added in v1.0.0
func (dst *AddressCommandSet) XXX_Merge(src proto.Message)
func (*AddressCommandSet) XXX_Size ¶ added in v1.0.0
func (m *AddressCommandSet) XXX_Size() int
func (*AddressCommandSet) XXX_Unmarshal ¶ added in v1.0.0
func (m *AddressCommandSet) XXX_Unmarshal(b []byte) error
type ConnectionConfig ¶
type ConnectionConfig struct { MinConns uint32 `protobuf:"varint,1,opt,name=min_conns,json=minConns,proto3" json:"min_conns,omitempty"` MaxConns uint32 `protobuf:"varint,2,opt,name=max_conns,json=maxConns,proto3" json:"max_conns,omitempty"` IdleConnTimeout uint32 `protobuf:"varint,3,opt,name=idle_conn_timeout,json=idleConnTimeout,proto3" json:"idle_conn_timeout,omitempty"` WaitConnTimeout uint32 `protobuf:"varint,4,opt,name=wait_conn_timeout,json=waitConnTimeout,proto3" json:"wait_conn_timeout,omitempty"` ClearPeriod uint32 `protobuf:"varint,5,opt,name=clear_period,json=clearPeriod,proto3" json:"clear_period,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectionConfig) Descriptor ¶
func (*ConnectionConfig) Descriptor() ([]byte, []int)
func (*ConnectionConfig) GetClearPeriod ¶
func (m *ConnectionConfig) GetClearPeriod() uint32
func (*ConnectionConfig) GetIdleConnTimeout ¶
func (m *ConnectionConfig) GetIdleConnTimeout() uint32
func (*ConnectionConfig) GetMaxConns ¶
func (m *ConnectionConfig) GetMaxConns() uint32
func (*ConnectionConfig) GetMinConns ¶
func (m *ConnectionConfig) GetMinConns() uint32
func (*ConnectionConfig) GetWaitConnTimeout ¶
func (m *ConnectionConfig) GetWaitConnTimeout() uint32
func (*ConnectionConfig) ProtoMessage ¶
func (*ConnectionConfig) ProtoMessage()
func (*ConnectionConfig) Reset ¶
func (m *ConnectionConfig) Reset()
func (*ConnectionConfig) String ¶
func (m *ConnectionConfig) String() string
func (*ConnectionConfig) XXX_DiscardUnknown ¶
func (m *ConnectionConfig) XXX_DiscardUnknown()
func (*ConnectionConfig) XXX_Marshal ¶
func (m *ConnectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectionConfig) XXX_Merge ¶
func (dst *ConnectionConfig) XXX_Merge(src proto.Message)
func (*ConnectionConfig) XXX_Size ¶
func (m *ConnectionConfig) XXX_Size() int
func (*ConnectionConfig) XXX_Unmarshal ¶
func (m *ConnectionConfig) XXX_Unmarshal(b []byte) error
type Constant ¶
type Constant struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Constant) Descriptor ¶
func (*Constant) ProtoMessage ¶
func (*Constant) ProtoMessage()
func (*Constant) XXX_DiscardUnknown ¶
func (m *Constant) XXX_DiscardUnknown()
func (*Constant) XXX_Marshal ¶
func (*Constant) XXX_Unmarshal ¶
type Constant_ContentType ¶
type Constant_ContentType int32
const ( Constant_CONTENT_TYPE_UNKNOWN Constant_ContentType = 0 Constant_CONTENT_TYPE_JSON Constant_ContentType = 1 Constant_CONTENT_TYPE_FORM_DATA Constant_ContentType = 2 Constant_CONTENT_TYPE_X_WWW_FORM_URLENCODED Constant_ContentType = 3 )
func (Constant_ContentType) EnumDescriptor ¶
func (Constant_ContentType) EnumDescriptor() ([]byte, []int)
func (Constant_ContentType) String ¶
func (x Constant_ContentType) String() string
type Constant_HttpMethod ¶
type Constant_HttpMethod int32
const ( Constant_HTTP_METHOD_UNKNOWN Constant_HttpMethod = 0 Constant_HTTP_METHOD_GET Constant_HttpMethod = 1 Constant_HTTP_METHOD_POST Constant_HttpMethod = 2 )
func (Constant_HttpMethod) EnumDescriptor ¶
func (Constant_HttpMethod) EnumDescriptor() ([]byte, []int)
func (Constant_HttpMethod) String ¶
func (x Constant_HttpMethod) String() string
type ErrorResponse ¶ added in v1.0.0
type ErrorResponse struct { DebugMessage string `protobuf:"bytes,1,opt,name=debug_message,json=debugMessage,proto3" json:"debug_message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ErrorResponse) Descriptor ¶ added in v1.0.0
func (*ErrorResponse) Descriptor() ([]byte, []int)
func (*ErrorResponse) GetDebugMessage ¶ added in v1.0.0
func (m *ErrorResponse) GetDebugMessage() string
func (*ErrorResponse) ProtoMessage ¶ added in v1.0.0
func (*ErrorResponse) ProtoMessage()
func (*ErrorResponse) Reset ¶ added in v1.0.0
func (m *ErrorResponse) Reset()
func (*ErrorResponse) String ¶ added in v1.0.0
func (m *ErrorResponse) String() string
func (*ErrorResponse) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *ErrorResponse) XXX_DiscardUnknown()
func (*ErrorResponse) XXX_Marshal ¶ added in v1.0.0
func (m *ErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ErrorResponse) XXX_Merge ¶ added in v1.0.0
func (dst *ErrorResponse) XXX_Merge(src proto.Message)
func (*ErrorResponse) XXX_Size ¶ added in v1.0.0
func (m *ErrorResponse) XXX_Size() int
func (*ErrorResponse) XXX_Unmarshal ¶ added in v1.0.0
func (m *ErrorResponse) XXX_Unmarshal(b []byte) error
type HealthCheckRequest ¶
type HealthCheckRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckRequest) Descriptor ¶
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
func (*HealthCheckRequest) GetAddress ¶
func (m *HealthCheckRequest) GetAddress() string
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) Reset ¶
func (m *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (m *HealthCheckRequest) String() string
func (*HealthCheckRequest) XXX_DiscardUnknown ¶
func (m *HealthCheckRequest) XXX_DiscardUnknown()
func (*HealthCheckRequest) XXX_Marshal ¶
func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckRequest) XXX_Merge ¶
func (dst *HealthCheckRequest) XXX_Merge(src proto.Message)
func (*HealthCheckRequest) XXX_Size ¶
func (m *HealthCheckRequest) XXX_Size() int
func (*HealthCheckRequest) XXX_Unmarshal ¶
func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
type HealthCheckResponse ¶
type HealthCheckResponse struct { DebugMessage string `protobuf:"bytes,1,opt,name=debug_message,json=debugMessage,proto3" json:"debug_message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckResponse) Descriptor ¶
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
func (*HealthCheckResponse) GetDebugMessage ¶
func (m *HealthCheckResponse) GetDebugMessage() string
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) Reset ¶
func (m *HealthCheckResponse) Reset()
func (*HealthCheckResponse) String ¶
func (m *HealthCheckResponse) String() string
func (*HealthCheckResponse) XXX_DiscardUnknown ¶
func (m *HealthCheckResponse) XXX_DiscardUnknown()
func (*HealthCheckResponse) XXX_Marshal ¶
func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckResponse) XXX_Merge ¶
func (dst *HealthCheckResponse) XXX_Merge(src proto.Message)
func (*HealthCheckResponse) XXX_Size ¶
func (m *HealthCheckResponse) XXX_Size() int
func (*HealthCheckResponse) XXX_Unmarshal ¶
func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error
type HttpConfig ¶
type HttpConfig struct { Method Constant_HttpMethod `protobuf:"varint,1,opt,name=method,proto3,enum=gactus.Constant_HttpMethod" json:"method,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HttpConfig) Descriptor ¶
func (*HttpConfig) Descriptor() ([]byte, []int)
func (*HttpConfig) GetMethod ¶
func (m *HttpConfig) GetMethod() Constant_HttpMethod
func (*HttpConfig) GetPath ¶
func (m *HttpConfig) GetPath() string
func (*HttpConfig) ProtoMessage ¶
func (*HttpConfig) ProtoMessage()
func (*HttpConfig) Reset ¶
func (m *HttpConfig) Reset()
func (*HttpConfig) String ¶
func (m *HttpConfig) String() string
func (*HttpConfig) XXX_DiscardUnknown ¶
func (m *HttpConfig) XXX_DiscardUnknown()
func (*HttpConfig) XXX_Marshal ¶
func (m *HttpConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HttpConfig) XXX_Merge ¶
func (dst *HttpConfig) XXX_Merge(src proto.Message)
func (*HttpConfig) XXX_Size ¶
func (m *HttpConfig) XXX_Size() int
func (*HttpConfig) XXX_Unmarshal ¶
func (m *HttpConfig) XXX_Unmarshal(b []byte) error
type ProcessorRegistry ¶
type ProcessorRegistry struct { Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` HttpConfig *HttpConfig `protobuf:"bytes,2,opt,name=http_config,json=httpConfig,proto3" json:"http_config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessorRegistry) Descriptor ¶
func (*ProcessorRegistry) Descriptor() ([]byte, []int)
func (*ProcessorRegistry) GetCommand ¶
func (m *ProcessorRegistry) GetCommand() string
func (*ProcessorRegistry) GetHttpConfig ¶
func (m *ProcessorRegistry) GetHttpConfig() *HttpConfig
func (*ProcessorRegistry) ProtoMessage ¶
func (*ProcessorRegistry) ProtoMessage()
func (*ProcessorRegistry) Reset ¶
func (m *ProcessorRegistry) Reset()
func (*ProcessorRegistry) String ¶
func (m *ProcessorRegistry) String() string
func (*ProcessorRegistry) XXX_DiscardUnknown ¶
func (m *ProcessorRegistry) XXX_DiscardUnknown()
func (*ProcessorRegistry) XXX_Marshal ¶
func (m *ProcessorRegistry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessorRegistry) XXX_Merge ¶
func (dst *ProcessorRegistry) XXX_Merge(src proto.Message)
func (*ProcessorRegistry) XXX_Size ¶
func (m *ProcessorRegistry) XXX_Size() int
func (*ProcessorRegistry) XXX_Unmarshal ¶
func (m *ProcessorRegistry) XXX_Unmarshal(b []byte) error
type RegisterServiceRequest ¶
type RegisterServiceRequest struct { AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"` Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"` ProcessorRegistries []*ProcessorRegistry `protobuf:"bytes,3,rep,name=processor_registries,json=processorRegistries,proto3" json:"processor_registries,omitempty"` ConnConfig *ConnectionConfig `protobuf:"bytes,4,opt,name=conn_config,json=connConfig,proto3" json:"conn_config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterServiceRequest) Descriptor ¶
func (*RegisterServiceRequest) Descriptor() ([]byte, []int)
func (*RegisterServiceRequest) GetAccessKey ¶ added in v1.0.0
func (m *RegisterServiceRequest) GetAccessKey() string
func (*RegisterServiceRequest) GetAddresses ¶
func (m *RegisterServiceRequest) GetAddresses() []string
func (*RegisterServiceRequest) GetConnConfig ¶
func (m *RegisterServiceRequest) GetConnConfig() *ConnectionConfig
func (*RegisterServiceRequest) GetProcessorRegistries ¶
func (m *RegisterServiceRequest) GetProcessorRegistries() []*ProcessorRegistry
func (*RegisterServiceRequest) ProtoMessage ¶
func (*RegisterServiceRequest) ProtoMessage()
func (*RegisterServiceRequest) Reset ¶
func (m *RegisterServiceRequest) Reset()
func (*RegisterServiceRequest) String ¶
func (m *RegisterServiceRequest) String() string
func (*RegisterServiceRequest) XXX_DiscardUnknown ¶
func (m *RegisterServiceRequest) XXX_DiscardUnknown()
func (*RegisterServiceRequest) XXX_Marshal ¶
func (m *RegisterServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterServiceRequest) XXX_Merge ¶
func (dst *RegisterServiceRequest) XXX_Merge(src proto.Message)
func (*RegisterServiceRequest) XXX_Size ¶
func (m *RegisterServiceRequest) XXX_Size() int
func (*RegisterServiceRequest) XXX_Unmarshal ¶
func (m *RegisterServiceRequest) XXX_Unmarshal(b []byte) error
type RegisterServiceResponse ¶
type RegisterServiceResponse struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterServiceResponse) Descriptor ¶
func (*RegisterServiceResponse) Descriptor() ([]byte, []int)
func (*RegisterServiceResponse) GetAddress ¶
func (m *RegisterServiceResponse) GetAddress() string
func (*RegisterServiceResponse) ProtoMessage ¶
func (*RegisterServiceResponse) ProtoMessage()
func (*RegisterServiceResponse) Reset ¶
func (m *RegisterServiceResponse) Reset()
func (*RegisterServiceResponse) String ¶
func (m *RegisterServiceResponse) String() string
func (*RegisterServiceResponse) XXX_DiscardUnknown ¶
func (m *RegisterServiceResponse) XXX_DiscardUnknown()
func (*RegisterServiceResponse) XXX_Marshal ¶
func (m *RegisterServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterServiceResponse) XXX_Merge ¶
func (dst *RegisterServiceResponse) XXX_Merge(src proto.Message)
func (*RegisterServiceResponse) XXX_Size ¶
func (m *RegisterServiceResponse) XXX_Size() int
func (*RegisterServiceResponse) XXX_Unmarshal ¶
func (m *RegisterServiceResponse) XXX_Unmarshal(b []byte) error
type Request ¶
type Request struct { HttpAddress string `protobuf:"bytes,1,opt,name=http_address,json=httpAddress,proto3" json:"http_address,omitempty"` LogId string `protobuf:"bytes,2,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"` Command string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` IsProto bool `protobuf:"varint,4,opt,name=is_proto,json=isProto,proto3" json:"is_proto,omitempty"` Header map[string]string `` /* 153-byte string literal not displayed */ Query map[string]string `` /* 151-byte string literal not displayed */ Body []byte `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"` ContentType Constant_ContentType `` /* 128-byte string literal not displayed */ RawContentType string `protobuf:"bytes,9,opt,name=raw_content_type,json=rawContentType,proto3" json:"raw_content_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetCommand ¶
func (*Request) GetContentType ¶
func (m *Request) GetContentType() Constant_ContentType
func (*Request) GetHttpAddress ¶
func (*Request) GetIsProto ¶
func (*Request) GetRawContentType ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type Response ¶
type Response struct { Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response) Descriptor ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type UpdateRegistriesRequest ¶
type UpdateRegistriesRequest struct { AddressCommands []*AddressCommandSet `protobuf:"bytes,1,rep,name=address_commands,json=addressCommands,proto3" json:"address_commands,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRegistriesRequest) Descriptor ¶
func (*UpdateRegistriesRequest) Descriptor() ([]byte, []int)
func (*UpdateRegistriesRequest) GetAddressCommands ¶ added in v1.0.0
func (m *UpdateRegistriesRequest) GetAddressCommands() []*AddressCommandSet
func (*UpdateRegistriesRequest) ProtoMessage ¶
func (*UpdateRegistriesRequest) ProtoMessage()
func (*UpdateRegistriesRequest) Reset ¶
func (m *UpdateRegistriesRequest) Reset()
func (*UpdateRegistriesRequest) String ¶
func (m *UpdateRegistriesRequest) String() string
func (*UpdateRegistriesRequest) XXX_DiscardUnknown ¶
func (m *UpdateRegistriesRequest) XXX_DiscardUnknown()
func (*UpdateRegistriesRequest) XXX_Marshal ¶
func (m *UpdateRegistriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRegistriesRequest) XXX_Merge ¶
func (dst *UpdateRegistriesRequest) XXX_Merge(src proto.Message)
func (*UpdateRegistriesRequest) XXX_Size ¶
func (m *UpdateRegistriesRequest) XXX_Size() int
func (*UpdateRegistriesRequest) XXX_Unmarshal ¶
func (m *UpdateRegistriesRequest) XXX_Unmarshal(b []byte) error
type UpdateRegistriesResponse ¶
type UpdateRegistriesResponse struct { DebugMessage string `protobuf:"bytes,1,opt,name=debug_message,json=debugMessage,proto3" json:"debug_message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRegistriesResponse) Descriptor ¶
func (*UpdateRegistriesResponse) Descriptor() ([]byte, []int)
func (*UpdateRegistriesResponse) GetDebugMessage ¶
func (m *UpdateRegistriesResponse) GetDebugMessage() string
func (*UpdateRegistriesResponse) ProtoMessage ¶
func (*UpdateRegistriesResponse) ProtoMessage()
func (*UpdateRegistriesResponse) Reset ¶
func (m *UpdateRegistriesResponse) Reset()
func (*UpdateRegistriesResponse) String ¶
func (m *UpdateRegistriesResponse) String() string
func (*UpdateRegistriesResponse) XXX_DiscardUnknown ¶
func (m *UpdateRegistriesResponse) XXX_DiscardUnknown()
func (*UpdateRegistriesResponse) XXX_Marshal ¶
func (m *UpdateRegistriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRegistriesResponse) XXX_Merge ¶
func (dst *UpdateRegistriesResponse) XXX_Merge(src proto.Message)
func (*UpdateRegistriesResponse) XXX_Size ¶
func (m *UpdateRegistriesResponse) XXX_Size() int
func (*UpdateRegistriesResponse) XXX_Unmarshal ¶
func (m *UpdateRegistriesResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.