pb

package
v0.0.0-...-f78b0ad Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type AgentClient 

type AgentClient interface {
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	Nemesis(ctx context.Context, in *NemesisRequest, opts ...grpc.CallOption) (*NemesisResponse, 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 AgentServer 

type AgentServer interface {
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	Nemesis(context.Context, *NemesisRequest) (*NemesisResponse, error)
}

AgentServer is the server API for Agent service.

type ControllerClient 

type ControllerClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer 

type ControllerServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
}

ControllerServer is the server API for Controller service.

type ExecRequest 

type ExecRequest struct {
	Command              string   `protobuf:"bytes,1,opt,name=Command,proto3" json:"Command,omitempty"`
	Background           bool     `protobuf:"varint,2,opt,name=Background,proto3" json:"Background,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecRequest) Descriptor 

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

func (*ExecRequest) GetBackground 

func (m *ExecRequest) GetBackground() bool

func (*ExecRequest) GetCommand 

func (m *ExecRequest) GetCommand() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) Reset 

func (m *ExecRequest) Reset()

func (*ExecRequest) String 

func (m *ExecRequest) String() string

func (*ExecRequest) XXX_DiscardUnknown 

func (m *ExecRequest) XXX_DiscardUnknown()

func (*ExecRequest) XXX_Marshal 

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

func (*ExecRequest) XXX_Merge 

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

func (*ExecRequest) XXX_Size 

func (m *ExecRequest) XXX_Size() int

func (*ExecRequest) XXX_Unmarshal 

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

type ExecResponse 

type ExecResponse struct {
	Stdout               string   `protobuf:"bytes,1,opt,name=Stdout,proto3" json:"Stdout,omitempty"`
	Stderr               string   `protobuf:"bytes,2,opt,name=Stderr,proto3" json:"Stderr,omitempty"`
	Code                 int32    `protobuf:"varint,3,opt,name=Code,proto3" json:"Code,omitempty"`
	ErrorMessage         string   `protobuf:"bytes,4,opt,name=ErrorMessage,proto3" json:"ErrorMessage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecResponse) Descriptor 

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

func (*ExecResponse) GetCode 

func (m *ExecResponse) GetCode() int32

func (*ExecResponse) GetErrorMessage 

func (m *ExecResponse) GetErrorMessage() string

func (*ExecResponse) GetStderr 

func (m *ExecResponse) GetStderr() string

func (*ExecResponse) GetStdout 

func (m *ExecResponse) GetStdout() string

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset 

func (m *ExecResponse) Reset()

func (*ExecResponse) String 

func (m *ExecResponse) String() string

func (*ExecResponse) XXX_DiscardUnknown 

func (m *ExecResponse) XXX_DiscardUnknown()

func (*ExecResponse) XXX_Marshal 

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

func (*ExecResponse) XXX_Merge 

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

func (*ExecResponse) XXX_Size 

func (m *ExecResponse) XXX_Size() int

func (*ExecResponse) XXX_Unmarshal 

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

type NemesisRequest 

type NemesisRequest struct {
	Type                 int32             `protobuf:"varint,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Arguments            map[string]string `` /* 159-byte string literal not displayed */
	ID                   string            `protobuf:"bytes,4,opt,name=ID,proto3" json:"ID,omitempty"`
	Op                   int32             `protobuf:"varint,5,opt,name=Op,proto3" json:"Op,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*NemesisRequest) Descriptor 

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

func (*NemesisRequest) GetArguments 

func (m *NemesisRequest) GetArguments() map[string]string

func (*NemesisRequest) GetID 

func (m *NemesisRequest) GetID() string

func (*NemesisRequest) GetName 

func (m *NemesisRequest) GetName() string

func (*NemesisRequest) GetOp 

func (m *NemesisRequest) GetOp() int32

func (*NemesisRequest) GetType 

func (m *NemesisRequest) GetType() int32

func (*NemesisRequest) ProtoMessage 

func (*NemesisRequest) ProtoMessage()

func (*NemesisRequest) Reset 

func (m *NemesisRequest) Reset()

func (*NemesisRequest) String 

func (m *NemesisRequest) String() string

func (*NemesisRequest) XXX_DiscardUnknown 

func (m *NemesisRequest) XXX_DiscardUnknown()

func (*NemesisRequest) XXX_Marshal 

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

func (*NemesisRequest) XXX_Merge 

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

func (*NemesisRequest) XXX_Size 

func (m *NemesisRequest) XXX_Size() int

func (*NemesisRequest) XXX_Unmarshal 

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

type NemesisResponse 

type NemesisResponse struct {
	Code                 int32    `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	ErrorMessage         string   `protobuf:"bytes,2,opt,name=ErrorMessage,proto3" json:"ErrorMessage,omitempty"`
	ID                   string   `protobuf:"bytes,3,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NemesisResponse) Descriptor 

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

func (*NemesisResponse) GetCode 

func (m *NemesisResponse) GetCode() int32

func (*NemesisResponse) GetErrorMessage 

func (m *NemesisResponse) GetErrorMessage() string

func (*NemesisResponse) GetID 

func (m *NemesisResponse) GetID() string

func (*NemesisResponse) ProtoMessage 

func (*NemesisResponse) ProtoMessage()

func (*NemesisResponse) Reset 

func (m *NemesisResponse) Reset()

func (*NemesisResponse) String 

func (m *NemesisResponse) String() string

func (*NemesisResponse) XXX_DiscardUnknown 

func (m *NemesisResponse) XXX_DiscardUnknown()

func (*NemesisResponse) XXX_Marshal 

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

func (*NemesisResponse) XXX_Merge 

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

func (*NemesisResponse) XXX_Size 

func (m *NemesisResponse) XXX_Size() int

func (*NemesisResponse) XXX_Unmarshal 

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

type RegisterRequest 

type RegisterRequest struct {
	Role                 string            `protobuf:"bytes,1,opt,name=Role,proto3" json:"Role,omitempty"`
	Address              string            `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	Version              string            `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Selector             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetAddress 

func (m *RegisterRequest) GetAddress() string

func (*RegisterRequest) GetRole 

func (m *RegisterRequest) GetRole() string

func (*RegisterRequest) GetSelector 

func (m *RegisterRequest) GetSelector() map[string]string

func (*RegisterRequest) GetVersion 

func (m *RegisterRequest) GetVersion() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

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

func (*RegisterRequest) XXX_Merge 

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

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

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

type RegisterResponse 

type RegisterResponse struct {
	Code                 int32    `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	ErrorMessage         string   `protobuf:"bytes,2,opt,name=ErrorMessage,proto3" json:"ErrorMessage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetCode 

func (m *RegisterResponse) GetCode() int32

func (*RegisterResponse) GetErrorMessage 

func (m *RegisterResponse) GetErrorMessage() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

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

func (*RegisterResponse) XXX_Merge 

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

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

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

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Exec 

func (*UnimplementedAgentServer) Exec(ctx context.Context, req *ExecRequest) (*ExecResponse, error)

func (*UnimplementedAgentServer) Nemesis 

func (*UnimplementedAgentServer) Nemesis(ctx context.Context, req *NemesisRequest) (*NemesisResponse, error)

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) Register 

func (*UnimplementedControllerServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, 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.