Documentation ¶
Index ¶
- Variables
- func RegisterAgentServer(s *grpc.Server, srv AgentServer)
- func RegisterDriverServer(s *grpc.Server, srv DriverServer)
- type AgentAddress
- func (*AgentAddress) Descriptor() ([]byte, []int)
- func (m *AgentAddress) GetHost() string
- func (m *AgentAddress) GetPort() int32
- func (m *AgentAddress) Marshal() (dAtA []byte, err error)
- func (m *AgentAddress) MarshalTo(dAtA []byte) (int, error)
- func (m *AgentAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AgentAddress) ProtoMessage()
- func (m *AgentAddress) Reset()
- func (m *AgentAddress) Size() (n int)
- func (m *AgentAddress) String() string
- func (m *AgentAddress) Unmarshal(dAtA []byte) error
- func (m *AgentAddress) XXX_DiscardUnknown()
- func (m *AgentAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AgentAddress) XXX_Merge(src proto.Message)
- func (m *AgentAddress) XXX_Size() int
- func (m *AgentAddress) XXX_Unmarshal(b []byte) error
- type AgentClient
- type AgentConfig
- func (*AgentConfig) Descriptor() ([]byte, []int)
- func (m *AgentConfig) GetProtocol() v1.ProtocolConfig
- func (m *AgentConfig) Marshal() (dAtA []byte, err error)
- func (m *AgentConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *AgentConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AgentConfig) ProtoMessage()
- func (m *AgentConfig) Reset()
- func (m *AgentConfig) Size() (n int)
- func (m *AgentConfig) String() string
- func (m *AgentConfig) Unmarshal(dAtA []byte) error
- func (m *AgentConfig) XXX_DiscardUnknown()
- func (m *AgentConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AgentConfig) XXX_Merge(src proto.Message)
- func (m *AgentConfig) XXX_Size() int
- func (m *AgentConfig) XXX_Unmarshal(b []byte) error
- type AgentId
- func (*AgentId) Descriptor() ([]byte, []int)
- func (m *AgentId) Marshal() (dAtA []byte, err error)
- func (m *AgentId) MarshalTo(dAtA []byte) (int, error)
- func (m *AgentId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AgentId) ProtoMessage()
- func (m *AgentId) Reset()
- func (m *AgentId) Size() (n int)
- func (m *AgentId) String() string
- func (m *AgentId) Unmarshal(dAtA []byte) error
- func (m *AgentId) XXX_DiscardUnknown()
- func (m *AgentId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AgentId) XXX_Merge(src proto.Message)
- func (m *AgentId) XXX_Size() int
- func (m *AgentId) XXX_Unmarshal(b []byte) error
- type AgentServer
- type ConfigureAgentRequest
- func (*ConfigureAgentRequest) Descriptor() ([]byte, []int)
- func (m *ConfigureAgentRequest) GetAgentID() AgentId
- func (m *ConfigureAgentRequest) GetConfig() AgentConfig
- func (m *ConfigureAgentRequest) Marshal() (dAtA []byte, err error)
- func (m *ConfigureAgentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigureAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigureAgentRequest) ProtoMessage()
- func (m *ConfigureAgentRequest) Reset()
- func (m *ConfigureAgentRequest) Size() (n int)
- func (m *ConfigureAgentRequest) String() string
- func (m *ConfigureAgentRequest) Unmarshal(dAtA []byte) error
- func (m *ConfigureAgentRequest) XXX_DiscardUnknown()
- func (m *ConfigureAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigureAgentRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureAgentRequest) XXX_Size() int
- func (m *ConfigureAgentRequest) XXX_Unmarshal(b []byte) error
- type ConfigureAgentResponse
- func (*ConfigureAgentResponse) Descriptor() ([]byte, []int)
- func (m *ConfigureAgentResponse) Marshal() (dAtA []byte, err error)
- func (m *ConfigureAgentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigureAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigureAgentResponse) ProtoMessage()
- func (m *ConfigureAgentResponse) Reset()
- func (m *ConfigureAgentResponse) Size() (n int)
- func (m *ConfigureAgentResponse) String() string
- func (m *ConfigureAgentResponse) Unmarshal(dAtA []byte) error
- func (m *ConfigureAgentResponse) XXX_DiscardUnknown()
- func (m *ConfigureAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigureAgentResponse) XXX_Merge(src proto.Message)
- func (m *ConfigureAgentResponse) XXX_Size() int
- func (m *ConfigureAgentResponse) XXX_Unmarshal(b []byte) error
- type CreateProxyRequest
- func (*CreateProxyRequest) Descriptor() ([]byte, []int)
- func (m *CreateProxyRequest) GetOptions() ProxyOptions
- func (m *CreateProxyRequest) GetProxyID() ProxyId
- func (m *CreateProxyRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateProxyRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateProxyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateProxyRequest) ProtoMessage()
- func (m *CreateProxyRequest) Reset()
- func (m *CreateProxyRequest) Size() (n int)
- func (m *CreateProxyRequest) String() string
- func (m *CreateProxyRequest) Unmarshal(dAtA []byte) error
- func (m *CreateProxyRequest) XXX_DiscardUnknown()
- func (m *CreateProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateProxyRequest) XXX_Merge(src proto.Message)
- func (m *CreateProxyRequest) XXX_Size() int
- func (m *CreateProxyRequest) XXX_Unmarshal(b []byte) error
- type CreateProxyResponse
- func (*CreateProxyResponse) Descriptor() ([]byte, []int)
- func (m *CreateProxyResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateProxyResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateProxyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateProxyResponse) ProtoMessage()
- func (m *CreateProxyResponse) Reset()
- func (m *CreateProxyResponse) Size() (n int)
- func (m *CreateProxyResponse) String() string
- func (m *CreateProxyResponse) Unmarshal(dAtA []byte) error
- func (m *CreateProxyResponse) XXX_DiscardUnknown()
- func (m *CreateProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateProxyResponse) XXX_Merge(src proto.Message)
- func (m *CreateProxyResponse) XXX_Size() int
- func (m *CreateProxyResponse) XXX_Unmarshal(b []byte) error
- type DestroyProxyRequest
- func (*DestroyProxyRequest) Descriptor() ([]byte, []int)
- func (m *DestroyProxyRequest) GetProxyID() ProxyId
- func (m *DestroyProxyRequest) Marshal() (dAtA []byte, err error)
- func (m *DestroyProxyRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DestroyProxyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DestroyProxyRequest) ProtoMessage()
- func (m *DestroyProxyRequest) Reset()
- func (m *DestroyProxyRequest) Size() (n int)
- func (m *DestroyProxyRequest) String() string
- func (m *DestroyProxyRequest) Unmarshal(dAtA []byte) error
- func (m *DestroyProxyRequest) XXX_DiscardUnknown()
- func (m *DestroyProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyProxyRequest) XXX_Merge(src proto.Message)
- func (m *DestroyProxyRequest) XXX_Size() int
- func (m *DestroyProxyRequest) XXX_Unmarshal(b []byte) error
- type DestroyProxyResponse
- func (*DestroyProxyResponse) Descriptor() ([]byte, []int)
- func (m *DestroyProxyResponse) Marshal() (dAtA []byte, err error)
- func (m *DestroyProxyResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DestroyProxyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DestroyProxyResponse) ProtoMessage()
- func (m *DestroyProxyResponse) Reset()
- func (m *DestroyProxyResponse) Size() (n int)
- func (m *DestroyProxyResponse) String() string
- func (m *DestroyProxyResponse) Unmarshal(dAtA []byte) error
- func (m *DestroyProxyResponse) XXX_DiscardUnknown()
- func (m *DestroyProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyProxyResponse) XXX_Merge(src proto.Message)
- func (m *DestroyProxyResponse) XXX_Size() int
- func (m *DestroyProxyResponse) XXX_Unmarshal(b []byte) error
- type DriverClient
- type DriverServer
- type ProxyId
- func (*ProxyId) Descriptor() ([]byte, []int)
- func (m *ProxyId) GetName() string
- func (m *ProxyId) GetType() string
- func (m *ProxyId) Marshal() (dAtA []byte, err error)
- func (m *ProxyId) MarshalTo(dAtA []byte) (int, error)
- func (m *ProxyId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProxyId) ProtoMessage()
- func (m *ProxyId) Reset()
- func (m *ProxyId) Size() (n int)
- func (m *ProxyId) String() string
- func (m *ProxyId) Unmarshal(dAtA []byte) error
- func (m *ProxyId) XXX_DiscardUnknown()
- func (m *ProxyId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyId) XXX_Merge(src proto.Message)
- func (m *ProxyId) XXX_Size() int
- func (m *ProxyId) XXX_Unmarshal(b []byte) error
- type ProxyOptions
- func (*ProxyOptions) Descriptor() ([]byte, []int)
- func (m *ProxyOptions) GetConfig() []byte
- func (m *ProxyOptions) GetRead() bool
- func (m *ProxyOptions) GetWrite() bool
- func (m *ProxyOptions) Marshal() (dAtA []byte, err error)
- func (m *ProxyOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *ProxyOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProxyOptions) ProtoMessage()
- func (m *ProxyOptions) Reset()
- func (m *ProxyOptions) Size() (n int)
- func (m *ProxyOptions) String() string
- func (m *ProxyOptions) Unmarshal(dAtA []byte) error
- func (m *ProxyOptions) XXX_DiscardUnknown()
- func (m *ProxyOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyOptions) XXX_Merge(src proto.Message)
- func (m *ProxyOptions) XXX_Size() int
- func (m *ProxyOptions) XXX_Unmarshal(b []byte) error
- type StartAgentRequest
- func (*StartAgentRequest) Descriptor() ([]byte, []int)
- func (m *StartAgentRequest) GetAddress() AgentAddress
- func (m *StartAgentRequest) GetAgentID() AgentId
- func (m *StartAgentRequest) GetConfig() AgentConfig
- func (m *StartAgentRequest) Marshal() (dAtA []byte, err error)
- func (m *StartAgentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StartAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartAgentRequest) ProtoMessage()
- func (m *StartAgentRequest) Reset()
- func (m *StartAgentRequest) Size() (n int)
- func (m *StartAgentRequest) String() string
- func (m *StartAgentRequest) Unmarshal(dAtA []byte) error
- func (m *StartAgentRequest) XXX_DiscardUnknown()
- func (m *StartAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartAgentRequest) XXX_Merge(src proto.Message)
- func (m *StartAgentRequest) XXX_Size() int
- func (m *StartAgentRequest) XXX_Unmarshal(b []byte) error
- type StartAgentResponse
- func (*StartAgentResponse) Descriptor() ([]byte, []int)
- func (m *StartAgentResponse) Marshal() (dAtA []byte, err error)
- func (m *StartAgentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StartAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartAgentResponse) ProtoMessage()
- func (m *StartAgentResponse) Reset()
- func (m *StartAgentResponse) Size() (n int)
- func (m *StartAgentResponse) String() string
- func (m *StartAgentResponse) Unmarshal(dAtA []byte) error
- func (m *StartAgentResponse) XXX_DiscardUnknown()
- func (m *StartAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartAgentResponse) XXX_Merge(src proto.Message)
- func (m *StartAgentResponse) XXX_Size() int
- func (m *StartAgentResponse) XXX_Unmarshal(b []byte) error
- type StopAgentRequest
- func (*StopAgentRequest) Descriptor() ([]byte, []int)
- func (m *StopAgentRequest) GetAgentID() AgentId
- func (m *StopAgentRequest) Marshal() (dAtA []byte, err error)
- func (m *StopAgentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StopAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StopAgentRequest) ProtoMessage()
- func (m *StopAgentRequest) Reset()
- func (m *StopAgentRequest) Size() (n int)
- func (m *StopAgentRequest) String() string
- func (m *StopAgentRequest) Unmarshal(dAtA []byte) error
- func (m *StopAgentRequest) XXX_DiscardUnknown()
- func (m *StopAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopAgentRequest) XXX_Merge(src proto.Message)
- func (m *StopAgentRequest) XXX_Size() int
- func (m *StopAgentRequest) XXX_Unmarshal(b []byte) error
- type StopAgentResponse
- func (*StopAgentResponse) Descriptor() ([]byte, []int)
- func (m *StopAgentResponse) Marshal() (dAtA []byte, err error)
- func (m *StopAgentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StopAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StopAgentResponse) ProtoMessage()
- func (m *StopAgentResponse) Reset()
- func (m *StopAgentResponse) Size() (n int)
- func (m *StopAgentResponse) String() string
- func (m *StopAgentResponse) Unmarshal(dAtA []byte) error
- func (m *StopAgentResponse) XXX_DiscardUnknown()
- func (m *StopAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopAgentResponse) XXX_Merge(src proto.Message)
- func (m *StopAgentResponse) XXX_Size() int
- func (m *StopAgentResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedAgentServer
- type UnimplementedDriverServer
- func (*UnimplementedDriverServer) ConfigureAgent(ctx context.Context, req *ConfigureAgentRequest) (*ConfigureAgentResponse, error)
- func (*UnimplementedDriverServer) StartAgent(ctx context.Context, req *StartAgentRequest) (*StartAgentResponse, error)
- func (*UnimplementedDriverServer) StopAgent(ctx context.Context, req *StopAgentRequest) (*StopAgentResponse, error)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterAgentServer ¶
func RegisterAgentServer(s *grpc.Server, srv AgentServer)
func RegisterDriverServer ¶
func RegisterDriverServer(s *grpc.Server, srv DriverServer)
Types ¶
type AgentAddress ¶
type AgentAddress struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` }
func (*AgentAddress) Descriptor ¶
func (*AgentAddress) Descriptor() ([]byte, []int)
func (*AgentAddress) GetHost ¶
func (m *AgentAddress) GetHost() string
func (*AgentAddress) GetPort ¶
func (m *AgentAddress) GetPort() int32
func (*AgentAddress) Marshal ¶
func (m *AgentAddress) Marshal() (dAtA []byte, err error)
func (*AgentAddress) MarshalToSizedBuffer ¶
func (m *AgentAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AgentAddress) ProtoMessage ¶
func (*AgentAddress) ProtoMessage()
func (*AgentAddress) Reset ¶
func (m *AgentAddress) Reset()
func (*AgentAddress) Size ¶
func (m *AgentAddress) Size() (n int)
func (*AgentAddress) String ¶
func (m *AgentAddress) String() string
func (*AgentAddress) Unmarshal ¶
func (m *AgentAddress) Unmarshal(dAtA []byte) error
func (*AgentAddress) XXX_DiscardUnknown ¶
func (m *AgentAddress) XXX_DiscardUnknown()
func (*AgentAddress) XXX_Marshal ¶
func (m *AgentAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AgentAddress) XXX_Merge ¶
func (m *AgentAddress) XXX_Merge(src proto.Message)
func (*AgentAddress) XXX_Size ¶
func (m *AgentAddress) XXX_Size() int
func (*AgentAddress) XXX_Unmarshal ¶
func (m *AgentAddress) XXX_Unmarshal(b []byte) error
type AgentClient ¶
type AgentClient interface { CreateProxy(ctx context.Context, in *CreateProxyRequest, opts ...grpc.CallOption) (*CreateProxyResponse, error) DestroyProxy(ctx context.Context, in *DestroyProxyRequest, opts ...grpc.CallOption) (*DestroyProxyResponse, error) }
AgentClient is the client API for Agent service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAgentClient ¶
func NewAgentClient(cc *grpc.ClientConn) AgentClient
type AgentConfig ¶
type AgentConfig struct {
Protocol v1.ProtocolConfig `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol"`
}
func (*AgentConfig) Descriptor ¶
func (*AgentConfig) Descriptor() ([]byte, []int)
func (*AgentConfig) GetProtocol ¶
func (m *AgentConfig) GetProtocol() v1.ProtocolConfig
func (*AgentConfig) Marshal ¶
func (m *AgentConfig) Marshal() (dAtA []byte, err error)
func (*AgentConfig) MarshalToSizedBuffer ¶
func (m *AgentConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AgentConfig) ProtoMessage ¶
func (*AgentConfig) ProtoMessage()
func (*AgentConfig) Reset ¶
func (m *AgentConfig) Reset()
func (*AgentConfig) Size ¶
func (m *AgentConfig) Size() (n int)
func (*AgentConfig) String ¶
func (m *AgentConfig) String() string
func (*AgentConfig) Unmarshal ¶
func (m *AgentConfig) Unmarshal(dAtA []byte) error
func (*AgentConfig) XXX_DiscardUnknown ¶
func (m *AgentConfig) XXX_DiscardUnknown()
func (*AgentConfig) XXX_Marshal ¶
func (m *AgentConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AgentConfig) XXX_Merge ¶
func (m *AgentConfig) XXX_Merge(src proto.Message)
func (*AgentConfig) XXX_Size ¶
func (m *AgentConfig) XXX_Size() int
func (*AgentConfig) XXX_Unmarshal ¶
func (m *AgentConfig) XXX_Unmarshal(b []byte) error
type AgentId ¶
type AgentId struct {
v1.ProtocolId `protobuf:"bytes,1,opt,name=protocol_id,json=protocolId,proto3,embedded=protocol_id" json:"protocol_id"`
}
func (*AgentId) Descriptor ¶
func (*AgentId) MarshalToSizedBuffer ¶
func (*AgentId) ProtoMessage ¶
func (*AgentId) ProtoMessage()
func (*AgentId) XXX_DiscardUnknown ¶
func (m *AgentId) XXX_DiscardUnknown()
func (*AgentId) XXX_Marshal ¶
func (*AgentId) XXX_Unmarshal ¶
type AgentServer ¶
type AgentServer interface { CreateProxy(context.Context, *CreateProxyRequest) (*CreateProxyResponse, error) DestroyProxy(context.Context, *DestroyProxyRequest) (*DestroyProxyResponse, error) }
AgentServer is the server API for Agent service.
type ConfigureAgentRequest ¶
type ConfigureAgentRequest struct { AgentID AgentId `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id"` Config AgentConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config"` }
func (*ConfigureAgentRequest) Descriptor ¶
func (*ConfigureAgentRequest) Descriptor() ([]byte, []int)
func (*ConfigureAgentRequest) GetAgentID ¶
func (m *ConfigureAgentRequest) GetAgentID() AgentId
func (*ConfigureAgentRequest) GetConfig ¶
func (m *ConfigureAgentRequest) GetConfig() AgentConfig
func (*ConfigureAgentRequest) Marshal ¶
func (m *ConfigureAgentRequest) Marshal() (dAtA []byte, err error)
func (*ConfigureAgentRequest) MarshalTo ¶
func (m *ConfigureAgentRequest) MarshalTo(dAtA []byte) (int, error)
func (*ConfigureAgentRequest) MarshalToSizedBuffer ¶
func (m *ConfigureAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigureAgentRequest) ProtoMessage ¶
func (*ConfigureAgentRequest) ProtoMessage()
func (*ConfigureAgentRequest) Reset ¶
func (m *ConfigureAgentRequest) Reset()
func (*ConfigureAgentRequest) Size ¶
func (m *ConfigureAgentRequest) Size() (n int)
func (*ConfigureAgentRequest) String ¶
func (m *ConfigureAgentRequest) String() string
func (*ConfigureAgentRequest) Unmarshal ¶
func (m *ConfigureAgentRequest) Unmarshal(dAtA []byte) error
func (*ConfigureAgentRequest) XXX_DiscardUnknown ¶
func (m *ConfigureAgentRequest) XXX_DiscardUnknown()
func (*ConfigureAgentRequest) XXX_Marshal ¶
func (m *ConfigureAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureAgentRequest) XXX_Merge ¶
func (m *ConfigureAgentRequest) XXX_Merge(src proto.Message)
func (*ConfigureAgentRequest) XXX_Size ¶
func (m *ConfigureAgentRequest) XXX_Size() int
func (*ConfigureAgentRequest) XXX_Unmarshal ¶
func (m *ConfigureAgentRequest) XXX_Unmarshal(b []byte) error
type ConfigureAgentResponse ¶
type ConfigureAgentResponse struct { }
func (*ConfigureAgentResponse) Descriptor ¶
func (*ConfigureAgentResponse) Descriptor() ([]byte, []int)
func (*ConfigureAgentResponse) Marshal ¶
func (m *ConfigureAgentResponse) Marshal() (dAtA []byte, err error)
func (*ConfigureAgentResponse) MarshalTo ¶
func (m *ConfigureAgentResponse) MarshalTo(dAtA []byte) (int, error)
func (*ConfigureAgentResponse) MarshalToSizedBuffer ¶
func (m *ConfigureAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigureAgentResponse) ProtoMessage ¶
func (*ConfigureAgentResponse) ProtoMessage()
func (*ConfigureAgentResponse) Reset ¶
func (m *ConfigureAgentResponse) Reset()
func (*ConfigureAgentResponse) Size ¶
func (m *ConfigureAgentResponse) Size() (n int)
func (*ConfigureAgentResponse) String ¶
func (m *ConfigureAgentResponse) String() string
func (*ConfigureAgentResponse) Unmarshal ¶
func (m *ConfigureAgentResponse) Unmarshal(dAtA []byte) error
func (*ConfigureAgentResponse) XXX_DiscardUnknown ¶
func (m *ConfigureAgentResponse) XXX_DiscardUnknown()
func (*ConfigureAgentResponse) XXX_Marshal ¶
func (m *ConfigureAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureAgentResponse) XXX_Merge ¶
func (m *ConfigureAgentResponse) XXX_Merge(src proto.Message)
func (*ConfigureAgentResponse) XXX_Size ¶
func (m *ConfigureAgentResponse) XXX_Size() int
func (*ConfigureAgentResponse) XXX_Unmarshal ¶
func (m *ConfigureAgentResponse) XXX_Unmarshal(b []byte) error
type CreateProxyRequest ¶
type CreateProxyRequest struct { ProxyID ProxyId `protobuf:"bytes,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id"` Options ProxyOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options"` }
func (*CreateProxyRequest) Descriptor ¶
func (*CreateProxyRequest) Descriptor() ([]byte, []int)
func (*CreateProxyRequest) GetOptions ¶
func (m *CreateProxyRequest) GetOptions() ProxyOptions
func (*CreateProxyRequest) GetProxyID ¶
func (m *CreateProxyRequest) GetProxyID() ProxyId
func (*CreateProxyRequest) Marshal ¶
func (m *CreateProxyRequest) Marshal() (dAtA []byte, err error)
func (*CreateProxyRequest) MarshalTo ¶
func (m *CreateProxyRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateProxyRequest) MarshalToSizedBuffer ¶
func (m *CreateProxyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateProxyRequest) ProtoMessage ¶
func (*CreateProxyRequest) ProtoMessage()
func (*CreateProxyRequest) Reset ¶
func (m *CreateProxyRequest) Reset()
func (*CreateProxyRequest) Size ¶
func (m *CreateProxyRequest) Size() (n int)
func (*CreateProxyRequest) String ¶
func (m *CreateProxyRequest) String() string
func (*CreateProxyRequest) Unmarshal ¶
func (m *CreateProxyRequest) Unmarshal(dAtA []byte) error
func (*CreateProxyRequest) XXX_DiscardUnknown ¶
func (m *CreateProxyRequest) XXX_DiscardUnknown()
func (*CreateProxyRequest) XXX_Marshal ¶
func (m *CreateProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateProxyRequest) XXX_Merge ¶
func (m *CreateProxyRequest) XXX_Merge(src proto.Message)
func (*CreateProxyRequest) XXX_Size ¶
func (m *CreateProxyRequest) XXX_Size() int
func (*CreateProxyRequest) XXX_Unmarshal ¶
func (m *CreateProxyRequest) XXX_Unmarshal(b []byte) error
type CreateProxyResponse ¶
type CreateProxyResponse struct { }
func (*CreateProxyResponse) Descriptor ¶
func (*CreateProxyResponse) Descriptor() ([]byte, []int)
func (*CreateProxyResponse) Marshal ¶
func (m *CreateProxyResponse) Marshal() (dAtA []byte, err error)
func (*CreateProxyResponse) MarshalTo ¶
func (m *CreateProxyResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateProxyResponse) MarshalToSizedBuffer ¶
func (m *CreateProxyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateProxyResponse) ProtoMessage ¶
func (*CreateProxyResponse) ProtoMessage()
func (*CreateProxyResponse) Reset ¶
func (m *CreateProxyResponse) Reset()
func (*CreateProxyResponse) Size ¶
func (m *CreateProxyResponse) Size() (n int)
func (*CreateProxyResponse) String ¶
func (m *CreateProxyResponse) String() string
func (*CreateProxyResponse) Unmarshal ¶
func (m *CreateProxyResponse) Unmarshal(dAtA []byte) error
func (*CreateProxyResponse) XXX_DiscardUnknown ¶
func (m *CreateProxyResponse) XXX_DiscardUnknown()
func (*CreateProxyResponse) XXX_Marshal ¶
func (m *CreateProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateProxyResponse) XXX_Merge ¶
func (m *CreateProxyResponse) XXX_Merge(src proto.Message)
func (*CreateProxyResponse) XXX_Size ¶
func (m *CreateProxyResponse) XXX_Size() int
func (*CreateProxyResponse) XXX_Unmarshal ¶
func (m *CreateProxyResponse) XXX_Unmarshal(b []byte) error
type DestroyProxyRequest ¶
type DestroyProxyRequest struct {
ProxyID ProxyId `protobuf:"bytes,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id"`
}
func (*DestroyProxyRequest) Descriptor ¶
func (*DestroyProxyRequest) Descriptor() ([]byte, []int)
func (*DestroyProxyRequest) GetProxyID ¶
func (m *DestroyProxyRequest) GetProxyID() ProxyId
func (*DestroyProxyRequest) Marshal ¶
func (m *DestroyProxyRequest) Marshal() (dAtA []byte, err error)
func (*DestroyProxyRequest) MarshalTo ¶
func (m *DestroyProxyRequest) MarshalTo(dAtA []byte) (int, error)
func (*DestroyProxyRequest) MarshalToSizedBuffer ¶
func (m *DestroyProxyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DestroyProxyRequest) ProtoMessage ¶
func (*DestroyProxyRequest) ProtoMessage()
func (*DestroyProxyRequest) Reset ¶
func (m *DestroyProxyRequest) Reset()
func (*DestroyProxyRequest) Size ¶
func (m *DestroyProxyRequest) Size() (n int)
func (*DestroyProxyRequest) String ¶
func (m *DestroyProxyRequest) String() string
func (*DestroyProxyRequest) Unmarshal ¶
func (m *DestroyProxyRequest) Unmarshal(dAtA []byte) error
func (*DestroyProxyRequest) XXX_DiscardUnknown ¶
func (m *DestroyProxyRequest) XXX_DiscardUnknown()
func (*DestroyProxyRequest) XXX_Marshal ¶
func (m *DestroyProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroyProxyRequest) XXX_Merge ¶
func (m *DestroyProxyRequest) XXX_Merge(src proto.Message)
func (*DestroyProxyRequest) XXX_Size ¶
func (m *DestroyProxyRequest) XXX_Size() int
func (*DestroyProxyRequest) XXX_Unmarshal ¶
func (m *DestroyProxyRequest) XXX_Unmarshal(b []byte) error
type DestroyProxyResponse ¶
type DestroyProxyResponse struct { }
func (*DestroyProxyResponse) Descriptor ¶
func (*DestroyProxyResponse) Descriptor() ([]byte, []int)
func (*DestroyProxyResponse) Marshal ¶
func (m *DestroyProxyResponse) Marshal() (dAtA []byte, err error)
func (*DestroyProxyResponse) MarshalTo ¶
func (m *DestroyProxyResponse) MarshalTo(dAtA []byte) (int, error)
func (*DestroyProxyResponse) MarshalToSizedBuffer ¶
func (m *DestroyProxyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DestroyProxyResponse) ProtoMessage ¶
func (*DestroyProxyResponse) ProtoMessage()
func (*DestroyProxyResponse) Reset ¶
func (m *DestroyProxyResponse) Reset()
func (*DestroyProxyResponse) Size ¶
func (m *DestroyProxyResponse) Size() (n int)
func (*DestroyProxyResponse) String ¶
func (m *DestroyProxyResponse) String() string
func (*DestroyProxyResponse) Unmarshal ¶
func (m *DestroyProxyResponse) Unmarshal(dAtA []byte) error
func (*DestroyProxyResponse) XXX_DiscardUnknown ¶
func (m *DestroyProxyResponse) XXX_DiscardUnknown()
func (*DestroyProxyResponse) XXX_Marshal ¶
func (m *DestroyProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroyProxyResponse) XXX_Merge ¶
func (m *DestroyProxyResponse) XXX_Merge(src proto.Message)
func (*DestroyProxyResponse) XXX_Size ¶
func (m *DestroyProxyResponse) XXX_Size() int
func (*DestroyProxyResponse) XXX_Unmarshal ¶
func (m *DestroyProxyResponse) XXX_Unmarshal(b []byte) error
type DriverClient ¶
type DriverClient interface { StartAgent(ctx context.Context, in *StartAgentRequest, opts ...grpc.CallOption) (*StartAgentResponse, error) ConfigureAgent(ctx context.Context, in *ConfigureAgentRequest, opts ...grpc.CallOption) (*ConfigureAgentResponse, error) StopAgent(ctx context.Context, in *StopAgentRequest, opts ...grpc.CallOption) (*StopAgentResponse, error) }
DriverClient is the client API for Driver service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDriverClient ¶
func NewDriverClient(cc *grpc.ClientConn) DriverClient
type DriverServer ¶
type DriverServer interface { StartAgent(context.Context, *StartAgentRequest) (*StartAgentResponse, error) ConfigureAgent(context.Context, *ConfigureAgentRequest) (*ConfigureAgentResponse, error) StopAgent(context.Context, *StopAgentRequest) (*StopAgentResponse, error) }
DriverServer is the server API for Driver service.
type ProxyId ¶
type ProxyId struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` }
func (*ProxyId) Descriptor ¶
func (*ProxyId) MarshalToSizedBuffer ¶
func (*ProxyId) ProtoMessage ¶
func (*ProxyId) ProtoMessage()
func (*ProxyId) XXX_DiscardUnknown ¶
func (m *ProxyId) XXX_DiscardUnknown()
func (*ProxyId) XXX_Marshal ¶
func (*ProxyId) XXX_Unmarshal ¶
type ProxyOptions ¶
type ProxyOptions struct { Read bool `protobuf:"varint,1,opt,name=read,proto3" json:"read,omitempty"` Write bool `protobuf:"varint,2,opt,name=write,proto3" json:"write,omitempty"` Config []byte `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` }
func (*ProxyOptions) Descriptor ¶
func (*ProxyOptions) Descriptor() ([]byte, []int)
func (*ProxyOptions) GetConfig ¶
func (m *ProxyOptions) GetConfig() []byte
func (*ProxyOptions) GetRead ¶
func (m *ProxyOptions) GetRead() bool
func (*ProxyOptions) GetWrite ¶
func (m *ProxyOptions) GetWrite() bool
func (*ProxyOptions) Marshal ¶
func (m *ProxyOptions) Marshal() (dAtA []byte, err error)
func (*ProxyOptions) MarshalToSizedBuffer ¶
func (m *ProxyOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProxyOptions) ProtoMessage ¶
func (*ProxyOptions) ProtoMessage()
func (*ProxyOptions) Reset ¶
func (m *ProxyOptions) Reset()
func (*ProxyOptions) Size ¶
func (m *ProxyOptions) Size() (n int)
func (*ProxyOptions) String ¶
func (m *ProxyOptions) String() string
func (*ProxyOptions) Unmarshal ¶
func (m *ProxyOptions) Unmarshal(dAtA []byte) error
func (*ProxyOptions) XXX_DiscardUnknown ¶
func (m *ProxyOptions) XXX_DiscardUnknown()
func (*ProxyOptions) XXX_Marshal ¶
func (m *ProxyOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyOptions) XXX_Merge ¶
func (m *ProxyOptions) XXX_Merge(src proto.Message)
func (*ProxyOptions) XXX_Size ¶
func (m *ProxyOptions) XXX_Size() int
func (*ProxyOptions) XXX_Unmarshal ¶
func (m *ProxyOptions) XXX_Unmarshal(b []byte) error
type StartAgentRequest ¶
type StartAgentRequest struct { AgentID AgentId `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id"` Address AgentAddress `protobuf:"bytes,2,opt,name=address,proto3" json:"address"` Config AgentConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config"` }
func (*StartAgentRequest) Descriptor ¶
func (*StartAgentRequest) Descriptor() ([]byte, []int)
func (*StartAgentRequest) GetAddress ¶
func (m *StartAgentRequest) GetAddress() AgentAddress
func (*StartAgentRequest) GetAgentID ¶
func (m *StartAgentRequest) GetAgentID() AgentId
func (*StartAgentRequest) GetConfig ¶
func (m *StartAgentRequest) GetConfig() AgentConfig
func (*StartAgentRequest) Marshal ¶
func (m *StartAgentRequest) Marshal() (dAtA []byte, err error)
func (*StartAgentRequest) MarshalTo ¶
func (m *StartAgentRequest) MarshalTo(dAtA []byte) (int, error)
func (*StartAgentRequest) MarshalToSizedBuffer ¶
func (m *StartAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartAgentRequest) ProtoMessage ¶
func (*StartAgentRequest) ProtoMessage()
func (*StartAgentRequest) Reset ¶
func (m *StartAgentRequest) Reset()
func (*StartAgentRequest) Size ¶
func (m *StartAgentRequest) Size() (n int)
func (*StartAgentRequest) String ¶
func (m *StartAgentRequest) String() string
func (*StartAgentRequest) Unmarshal ¶
func (m *StartAgentRequest) Unmarshal(dAtA []byte) error
func (*StartAgentRequest) XXX_DiscardUnknown ¶
func (m *StartAgentRequest) XXX_DiscardUnknown()
func (*StartAgentRequest) XXX_Marshal ¶
func (m *StartAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartAgentRequest) XXX_Merge ¶
func (m *StartAgentRequest) XXX_Merge(src proto.Message)
func (*StartAgentRequest) XXX_Size ¶
func (m *StartAgentRequest) XXX_Size() int
func (*StartAgentRequest) XXX_Unmarshal ¶
func (m *StartAgentRequest) XXX_Unmarshal(b []byte) error
type StartAgentResponse ¶
type StartAgentResponse struct { }
func (*StartAgentResponse) Descriptor ¶
func (*StartAgentResponse) Descriptor() ([]byte, []int)
func (*StartAgentResponse) Marshal ¶
func (m *StartAgentResponse) Marshal() (dAtA []byte, err error)
func (*StartAgentResponse) MarshalTo ¶
func (m *StartAgentResponse) MarshalTo(dAtA []byte) (int, error)
func (*StartAgentResponse) MarshalToSizedBuffer ¶
func (m *StartAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartAgentResponse) ProtoMessage ¶
func (*StartAgentResponse) ProtoMessage()
func (*StartAgentResponse) Reset ¶
func (m *StartAgentResponse) Reset()
func (*StartAgentResponse) Size ¶
func (m *StartAgentResponse) Size() (n int)
func (*StartAgentResponse) String ¶
func (m *StartAgentResponse) String() string
func (*StartAgentResponse) Unmarshal ¶
func (m *StartAgentResponse) Unmarshal(dAtA []byte) error
func (*StartAgentResponse) XXX_DiscardUnknown ¶
func (m *StartAgentResponse) XXX_DiscardUnknown()
func (*StartAgentResponse) XXX_Marshal ¶
func (m *StartAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartAgentResponse) XXX_Merge ¶
func (m *StartAgentResponse) XXX_Merge(src proto.Message)
func (*StartAgentResponse) XXX_Size ¶
func (m *StartAgentResponse) XXX_Size() int
func (*StartAgentResponse) XXX_Unmarshal ¶
func (m *StartAgentResponse) XXX_Unmarshal(b []byte) error
type StopAgentRequest ¶
type StopAgentRequest struct {
AgentID AgentId `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id"`
}
func (*StopAgentRequest) Descriptor ¶
func (*StopAgentRequest) Descriptor() ([]byte, []int)
func (*StopAgentRequest) GetAgentID ¶
func (m *StopAgentRequest) GetAgentID() AgentId
func (*StopAgentRequest) Marshal ¶
func (m *StopAgentRequest) Marshal() (dAtA []byte, err error)
func (*StopAgentRequest) MarshalToSizedBuffer ¶
func (m *StopAgentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StopAgentRequest) ProtoMessage ¶
func (*StopAgentRequest) ProtoMessage()
func (*StopAgentRequest) Reset ¶
func (m *StopAgentRequest) Reset()
func (*StopAgentRequest) Size ¶
func (m *StopAgentRequest) Size() (n int)
func (*StopAgentRequest) String ¶
func (m *StopAgentRequest) String() string
func (*StopAgentRequest) Unmarshal ¶
func (m *StopAgentRequest) Unmarshal(dAtA []byte) error
func (*StopAgentRequest) XXX_DiscardUnknown ¶
func (m *StopAgentRequest) XXX_DiscardUnknown()
func (*StopAgentRequest) XXX_Marshal ¶
func (m *StopAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopAgentRequest) XXX_Merge ¶
func (m *StopAgentRequest) XXX_Merge(src proto.Message)
func (*StopAgentRequest) XXX_Size ¶
func (m *StopAgentRequest) XXX_Size() int
func (*StopAgentRequest) XXX_Unmarshal ¶
func (m *StopAgentRequest) XXX_Unmarshal(b []byte) error
type StopAgentResponse ¶
type StopAgentResponse struct { }
func (*StopAgentResponse) Descriptor ¶
func (*StopAgentResponse) Descriptor() ([]byte, []int)
func (*StopAgentResponse) Marshal ¶
func (m *StopAgentResponse) Marshal() (dAtA []byte, err error)
func (*StopAgentResponse) MarshalTo ¶
func (m *StopAgentResponse) MarshalTo(dAtA []byte) (int, error)
func (*StopAgentResponse) MarshalToSizedBuffer ¶
func (m *StopAgentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StopAgentResponse) ProtoMessage ¶
func (*StopAgentResponse) ProtoMessage()
func (*StopAgentResponse) Reset ¶
func (m *StopAgentResponse) Reset()
func (*StopAgentResponse) Size ¶
func (m *StopAgentResponse) Size() (n int)
func (*StopAgentResponse) String ¶
func (m *StopAgentResponse) String() string
func (*StopAgentResponse) Unmarshal ¶
func (m *StopAgentResponse) Unmarshal(dAtA []byte) error
func (*StopAgentResponse) XXX_DiscardUnknown ¶
func (m *StopAgentResponse) XXX_DiscardUnknown()
func (*StopAgentResponse) XXX_Marshal ¶
func (m *StopAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopAgentResponse) XXX_Merge ¶
func (m *StopAgentResponse) XXX_Merge(src proto.Message)
func (*StopAgentResponse) XXX_Size ¶
func (m *StopAgentResponse) XXX_Size() int
func (*StopAgentResponse) XXX_Unmarshal ¶
func (m *StopAgentResponse) XXX_Unmarshal(b []byte) error
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct { }
UnimplementedAgentServer can be embedded to have forward compatible implementations.
func (*UnimplementedAgentServer) CreateProxy ¶
func (*UnimplementedAgentServer) CreateProxy(ctx context.Context, req *CreateProxyRequest) (*CreateProxyResponse, error)
func (*UnimplementedAgentServer) DestroyProxy ¶
func (*UnimplementedAgentServer) DestroyProxy(ctx context.Context, req *DestroyProxyRequest) (*DestroyProxyResponse, error)
type UnimplementedDriverServer ¶
type UnimplementedDriverServer struct { }
UnimplementedDriverServer can be embedded to have forward compatible implementations.
func (*UnimplementedDriverServer) ConfigureAgent ¶
func (*UnimplementedDriverServer) ConfigureAgent(ctx context.Context, req *ConfigureAgentRequest) (*ConfigureAgentResponse, error)
func (*UnimplementedDriverServer) StartAgent ¶
func (*UnimplementedDriverServer) StartAgent(ctx context.Context, req *StartAgentRequest) (*StartAgentResponse, error)
func (*UnimplementedDriverServer) StopAgent ¶
func (*UnimplementedDriverServer) StopAgent(ctx context.Context, req *StopAgentRequest) (*StopAgentResponse, error)
Click to show internal directories.
Click to hide internal directories.