types

package module
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2019 License: MIT Imports: 7 Imported by: 2

README

types

core types for AntSSH

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AgentAuthReq_Action_name = map[int32]string{
	0: "CONNECT",
	1: "EXECUTE",
	2: "PROXY",
	3: "FORWARD",
}
View Source 
var AgentAuthReq_Action_value = map[string]int32{
	"CONNECT": 0,
	"EXECUTE": 1,
	"PROXY":   2,
	"FORWARD": 3,
}
View Source 
var AgentRecordReq_Type_name = map[int32]string{
	0: "STDOUT",
	1: "STDERR",
	2: "WINSIZE",
}
View Source 
var AgentRecordReq_Type_value = map[string]int32{
	"STDOUT":  0,
	"STDERR":  1,
	"WINSIZE": 2,
}

Functions

func RegisterAgentControllerServer added in v0.2.0 

func RegisterAgentControllerServer(s *grpc.Server, srv AgentControllerServer)

Types

type AgentAuthReq 

type AgentAuthReq struct {
	Fingerprint string              `protobuf:"bytes,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	User        string              `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Hostname    string              `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Action      AgentAuthReq_Action `protobuf:"varint,4,opt,name=action,proto3,enum=antssh.AgentAuthReq_Action" json:"action,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*AgentAuthReq_Command
	//	*AgentAuthReq_Address
	Payload              isAgentAuthReq_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*AgentAuthReq) Descriptor 

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

func (*AgentAuthReq) GetAction 

func (m *AgentAuthReq) GetAction() AgentAuthReq_Action

func (*AgentAuthReq) GetAddress 

func (m *AgentAuthReq) GetAddress() string

func (*AgentAuthReq) GetCommand 

func (m *AgentAuthReq) GetCommand() string

func (*AgentAuthReq) GetFingerprint 

func (m *AgentAuthReq) GetFingerprint() string

func (*AgentAuthReq) GetHostname 

func (m *AgentAuthReq) GetHostname() string

func (*AgentAuthReq) GetPayload 

func (m *AgentAuthReq) GetPayload() isAgentAuthReq_Payload

func (*AgentAuthReq) GetUser 

func (m *AgentAuthReq) GetUser() string

func (*AgentAuthReq) ProtoMessage 

func (*AgentAuthReq) ProtoMessage()

func (*AgentAuthReq) Reset 

func (m *AgentAuthReq) Reset()

func (*AgentAuthReq) String 

func (m *AgentAuthReq) String() string

func (*AgentAuthReq) XXX_DiscardUnknown 

func (m *AgentAuthReq) XXX_DiscardUnknown()

func (*AgentAuthReq) XXX_Marshal 

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

func (*AgentAuthReq) XXX_Merge 

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

func (*AgentAuthReq) XXX_OneofWrappers 

func (*AgentAuthReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AgentAuthReq) XXX_Size 

func (m *AgentAuthReq) XXX_Size() int

func (*AgentAuthReq) XXX_Unmarshal 

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

type AgentAuthReq_Action 

type AgentAuthReq_Action int32
const (
	AgentAuthReq_CONNECT AgentAuthReq_Action = 0
	AgentAuthReq_EXECUTE AgentAuthReq_Action = 1
	AgentAuthReq_PROXY   AgentAuthReq_Action = 2
	AgentAuthReq_FORWARD AgentAuthReq_Action = 3
)

func (AgentAuthReq_Action) EnumDescriptor 

func (AgentAuthReq_Action) EnumDescriptor() ([]byte, []int)

func (AgentAuthReq_Action) String 

func (x AgentAuthReq_Action) String() string

type AgentAuthReq_Address 

type AgentAuthReq_Address struct {
	Address string `protobuf:"bytes,6,opt,name=address,proto3,oneof"`
}

type AgentAuthReq_Command 

type AgentAuthReq_Command struct {
	Command string `protobuf:"bytes,5,opt,name=command,proto3,oneof"`
}

type AgentAuthResp 

type AgentAuthResp struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RecordId             string   `protobuf:"bytes,3,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentAuthResp) Descriptor 

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

func (*AgentAuthResp) GetMessage 

func (m *AgentAuthResp) GetMessage() string

func (*AgentAuthResp) GetRecordId 

func (m *AgentAuthResp) GetRecordId() string

func (*AgentAuthResp) GetSuccess 

func (m *AgentAuthResp) GetSuccess() bool

func (*AgentAuthResp) ProtoMessage 

func (*AgentAuthResp) ProtoMessage()

func (*AgentAuthResp) Reset 

func (m *AgentAuthResp) Reset()

func (*AgentAuthResp) String 

func (m *AgentAuthResp) String() string

func (*AgentAuthResp) XXX_DiscardUnknown 

func (m *AgentAuthResp) XXX_DiscardUnknown()

func (*AgentAuthResp) XXX_Marshal 

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

func (*AgentAuthResp) XXX_Merge 

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

func (*AgentAuthResp) XXX_Size 

func (m *AgentAuthResp) XXX_Size() int

func (*AgentAuthResp) XXX_Unmarshal 

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

type AgentControllerClient added in v0.2.0 

type AgentControllerClient interface {
	Ping(ctx context.Context, in *AgentPingReq, opts ...grpc.CallOption) (*AgentPingResp, error)
	Auth(ctx context.Context, in *AgentAuthReq, opts ...grpc.CallOption) (*AgentAuthResp, error)
	Record(ctx context.Context, opts ...grpc.CallOption) (AgentController_RecordClient, error)
}

AgentControllerClient is the client API for AgentController service.

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

func NewAgentControllerClient added in v0.2.0 

func NewAgentControllerClient(cc *grpc.ClientConn) AgentControllerClient

type AgentControllerServer added in v0.2.0 

type AgentControllerServer interface {
	Ping(context.Context, *AgentPingReq) (*AgentPingResp, error)
	Auth(context.Context, *AgentAuthReq) (*AgentAuthResp, error)
	Record(AgentController_RecordServer) error
}

AgentControllerServer is the server API for AgentController service.

type AgentController_RecordClient added in v0.2.0 

type AgentController_RecordClient interface {
	Send(*AgentRecordReq) error
	CloseAndRecv() (*AgentRecordResp, error)
	grpc.ClientStream
}

type AgentController_RecordServer added in v0.2.0 

type AgentController_RecordServer interface {
	SendAndClose(*AgentRecordResp) error
	Recv() (*AgentRecordReq, error)
	grpc.ServerStream
}

type AgentPingReq 

type AgentPingReq struct {
	AgentId              string   `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Hostname             string   `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPingReq) Descriptor 

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

func (*AgentPingReq) GetAgentId 

func (m *AgentPingReq) GetAgentId() string

func (*AgentPingReq) GetHostname 

func (m *AgentPingReq) GetHostname() string

func (*AgentPingReq) GetPort 

func (m *AgentPingReq) GetPort() uint32

func (*AgentPingReq) ProtoMessage 

func (*AgentPingReq) ProtoMessage()

func (*AgentPingReq) Reset 

func (m *AgentPingReq) Reset()

func (*AgentPingReq) String 

func (m *AgentPingReq) String() string

func (*AgentPingReq) XXX_DiscardUnknown 

func (m *AgentPingReq) XXX_DiscardUnknown()

func (*AgentPingReq) XXX_Marshal 

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

func (*AgentPingReq) XXX_Merge 

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

func (*AgentPingReq) XXX_Size 

func (m *AgentPingReq) XXX_Size() int

func (*AgentPingReq) XXX_Unmarshal 

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

type AgentPingResp 

type AgentPingResp struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPingResp) Descriptor 

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

func (*AgentPingResp) GetMessage 

func (m *AgentPingResp) GetMessage() string

func (*AgentPingResp) GetSuccess 

func (m *AgentPingResp) GetSuccess() bool

func (*AgentPingResp) ProtoMessage 

func (*AgentPingResp) ProtoMessage()

func (*AgentPingResp) Reset 

func (m *AgentPingResp) Reset()

func (*AgentPingResp) String 

func (m *AgentPingResp) String() string

func (*AgentPingResp) XXX_DiscardUnknown 

func (m *AgentPingResp) XXX_DiscardUnknown()

func (*AgentPingResp) XXX_Marshal 

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

func (*AgentPingResp) XXX_Merge 

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

func (*AgentPingResp) XXX_Size 

func (m *AgentPingResp) XXX_Size() int

func (*AgentPingResp) XXX_Unmarshal 

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

type AgentRecordReq 

type AgentRecordReq struct {
	RecordId  string              `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	Timestamp uint64              `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Type      AgentRecordReq_Type `protobuf:"varint,3,opt,name=type,proto3,enum=antssh.AgentRecordReq_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*AgentRecordReq_Data
	//	*AgentRecordReq_Size
	Payload              isAgentRecordReq_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*AgentRecordReq) Descriptor 

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

func (*AgentRecordReq) GetData 

func (m *AgentRecordReq) GetData() []byte

func (*AgentRecordReq) GetPayload 

func (m *AgentRecordReq) GetPayload() isAgentRecordReq_Payload

func (*AgentRecordReq) GetRecordId 

func (m *AgentRecordReq) GetRecordId() string

func (*AgentRecordReq) GetSize 

func (m *AgentRecordReq) GetSize() *AgentRecordReq_WinSize

func (*AgentRecordReq) GetTimestamp 

func (m *AgentRecordReq) GetTimestamp() uint64

func (*AgentRecordReq) GetType 

func (m *AgentRecordReq) GetType() AgentRecordReq_Type

func (*AgentRecordReq) ProtoMessage 

func (*AgentRecordReq) ProtoMessage()

func (*AgentRecordReq) Reset 

func (m *AgentRecordReq) Reset()

func (*AgentRecordReq) String 

func (m *AgentRecordReq) String() string

func (*AgentRecordReq) XXX_DiscardUnknown 

func (m *AgentRecordReq) XXX_DiscardUnknown()

func (*AgentRecordReq) XXX_Marshal 

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

func (*AgentRecordReq) XXX_Merge 

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

func (*AgentRecordReq) XXX_OneofWrappers 

func (*AgentRecordReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AgentRecordReq) XXX_Size 

func (m *AgentRecordReq) XXX_Size() int

func (*AgentRecordReq) XXX_Unmarshal 

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

type AgentRecordReq_Data 

type AgentRecordReq_Data struct {
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3,oneof"`
}

type AgentRecordReq_Size 

type AgentRecordReq_Size struct {
	Size *AgentRecordReq_WinSize `protobuf:"bytes,5,opt,name=size,proto3,oneof"`
}

type AgentRecordReq_Type 

type AgentRecordReq_Type int32
const (
	AgentRecordReq_STDOUT  AgentRecordReq_Type = 0
	AgentRecordReq_STDERR  AgentRecordReq_Type = 1
	AgentRecordReq_WINSIZE AgentRecordReq_Type = 2
)

func (AgentRecordReq_Type) EnumDescriptor 

func (AgentRecordReq_Type) EnumDescriptor() ([]byte, []int)

func (AgentRecordReq_Type) String 

func (x AgentRecordReq_Type) String() string

type AgentRecordReq_WinSize 

type AgentRecordReq_WinSize struct {
	Width                int32    `protobuf:"varint,1,opt,name=width,proto3" json:"width,omitempty"`
	Height               int32    `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentRecordReq_WinSize) Descriptor 

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

func (*AgentRecordReq_WinSize) GetHeight 

func (m *AgentRecordReq_WinSize) GetHeight() int32

func (*AgentRecordReq_WinSize) GetWidth 

func (m *AgentRecordReq_WinSize) GetWidth() int32

func (*AgentRecordReq_WinSize) ProtoMessage 

func (*AgentRecordReq_WinSize) ProtoMessage()

func (*AgentRecordReq_WinSize) Reset 

func (m *AgentRecordReq_WinSize) Reset()

func (*AgentRecordReq_WinSize) String 

func (m *AgentRecordReq_WinSize) String() string

func (*AgentRecordReq_WinSize) XXX_DiscardUnknown 

func (m *AgentRecordReq_WinSize) XXX_DiscardUnknown()

func (*AgentRecordReq_WinSize) XXX_Marshal 

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

func (*AgentRecordReq_WinSize) XXX_Merge 

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

func (*AgentRecordReq_WinSize) XXX_Size 

func (m *AgentRecordReq_WinSize) XXX_Size() int

func (*AgentRecordReq_WinSize) XXX_Unmarshal 

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

type AgentRecordResp 

type AgentRecordResp struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentRecordResp) Descriptor 

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

func (*AgentRecordResp) GetMessage 

func (m *AgentRecordResp) GetMessage() string

func (*AgentRecordResp) GetSuccess 

func (m *AgentRecordResp) GetSuccess() bool

func (*AgentRecordResp) ProtoMessage 

func (*AgentRecordResp) ProtoMessage()

func (*AgentRecordResp) Reset 

func (m *AgentRecordResp) Reset()

func (*AgentRecordResp) String 

func (m *AgentRecordResp) String() string

func (*AgentRecordResp) XXX_DiscardUnknown 

func (m *AgentRecordResp) XXX_DiscardUnknown()

func (*AgentRecordResp) XXX_Marshal 

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

func (*AgentRecordResp) XXX_Merge 

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

func (*AgentRecordResp) XXX_Size 

func (m *AgentRecordResp) XXX_Size() int

func (*AgentRecordResp) XXX_Unmarshal 

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

type UnimplementedAgentControllerServer added in v0.2.0 

type UnimplementedAgentControllerServer struct {
}

UnimplementedAgentControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentControllerServer) Auth added in v0.2.0 

func (*UnimplementedAgentControllerServer) Auth(ctx context.Context, req *AgentAuthReq) (*AgentAuthResp, error)

func (*UnimplementedAgentControllerServer) Ping added in v0.2.0 

func (*UnimplementedAgentControllerServer) Ping(ctx context.Context, req *AgentPingReq) (*AgentPingResp, error)

func (*UnimplementedAgentControllerServer) Record added in v0.2.0 

func (*UnimplementedAgentControllerServer) Record(srv AgentController_RecordServer) 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.