v1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 11 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAgent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAgent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDriver        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDriver          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDriver = fmt.Errorf("proto: unexpected end of group")
)

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) MarshalTo 

func (m *AgentAddress) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *AgentConfig) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*AgentId) Marshal 

func (m *AgentId) Marshal() (dAtA []byte, err error)

func (*AgentId) MarshalTo 

func (m *AgentId) MarshalTo(dAtA []byte) (int, error)

func (*AgentId) MarshalToSizedBuffer 

func (m *AgentId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentId) ProtoMessage 

func (*AgentId) ProtoMessage()

func (*AgentId) Reset 

func (m *AgentId) Reset()

func (*AgentId) Size 

func (m *AgentId) Size() (n int)

func (*AgentId) String 

func (m *AgentId) String() string

func (*AgentId) Unmarshal 

func (m *AgentId) Unmarshal(dAtA []byte) error

func (*AgentId) XXX_DiscardUnknown 

func (m *AgentId) XXX_DiscardUnknown()

func (*AgentId) XXX_Marshal 

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

func (*AgentId) XXX_Merge 

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

func (*AgentId) XXX_Size 

func (m *AgentId) XXX_Size() int

func (*AgentId) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*ProxyId) GetName 

func (m *ProxyId) GetName() string

func (*ProxyId) GetType 

func (m *ProxyId) GetType() string

func (*ProxyId) Marshal 

func (m *ProxyId) Marshal() (dAtA []byte, err error)

func (*ProxyId) MarshalTo 

func (m *ProxyId) MarshalTo(dAtA []byte) (int, error)

func (*ProxyId) MarshalToSizedBuffer 

func (m *ProxyId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProxyId) ProtoMessage 

func (*ProxyId) ProtoMessage()

func (*ProxyId) Reset 

func (m *ProxyId) Reset()

func (*ProxyId) Size 

func (m *ProxyId) Size() (n int)

func (*ProxyId) String 

func (m *ProxyId) String() string

func (*ProxyId) Unmarshal 

func (m *ProxyId) Unmarshal(dAtA []byte) error

func (*ProxyId) XXX_DiscardUnknown 

func (m *ProxyId) XXX_DiscardUnknown()

func (*ProxyId) XXX_Marshal 

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

func (*ProxyId) XXX_Merge 

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

func (*ProxyId) XXX_Size 

func (m *ProxyId) XXX_Size() int

func (*ProxyId) XXX_Unmarshal 

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

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) MarshalTo 

func (m *ProxyOptions) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StopAgentRequest) MarshalTo(dAtA []byte) (int, 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)

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.