pb

package
Version: v0.0.0-...-67873a1 Latest Latest
Warning

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

Go to latest
Published: Aug 23, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthGrcp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrcp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGrcp = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterTransferServer

func RegisterTransferServer(s *grpc.Server, srv TransferServer)

Types

type Command

type Command struct {
	AgentCtrl            int32         `protobuf:"varint,1,opt,name=AgentCtrl,proto3" json:"AgentCtrl,omitempty"`
	Task                 *PluginTask   `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	Config               []*ConfigItem `protobuf:"bytes,3,rep,name=Config,proto3" json:"Config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

server --> agent

func (*Command) Descriptor

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

func (*Command) GetAgentCtrl

func (m *Command) GetAgentCtrl() int32

func (*Command) GetConfig

func (m *Command) GetConfig() []*ConfigItem

func (*Command) GetTask

func (m *Command) GetTask() *PluginTask

func (*Command) Marshal

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

func (*Command) MarshalTo

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

func (*Command) MarshalToSizedBuffer

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

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) Reset

func (m *Command) Reset()

func (*Command) Size

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

func (*Command) String

func (m *Command) String() string

func (*Command) Unmarshal

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

func (*Command) XXX_DiscardUnknown

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal

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

func (*Command) XXX_Merge

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

func (*Command) XXX_Size

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal

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

type ConfigItem

type ConfigItem struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	SHA256               string   `protobuf:"bytes,3,opt,name=SHA256,proto3" json:"SHA256,omitempty"`
	DownloadURL          []string `protobuf:"bytes,4,rep,name=DownloadURL,proto3" json:"DownloadURL,omitempty"`
	Detail               string   `protobuf:"bytes,5,opt,name=Detail,proto3" json:"Detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigItem) Descriptor

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

func (*ConfigItem) GetDetail

func (m *ConfigItem) GetDetail() string

func (*ConfigItem) GetDownloadURL

func (m *ConfigItem) GetDownloadURL() []string

func (*ConfigItem) GetName

func (m *ConfigItem) GetName() string

func (*ConfigItem) GetSHA256

func (m *ConfigItem) GetSHA256() string

func (*ConfigItem) GetVersion

func (m *ConfigItem) GetVersion() string

func (*ConfigItem) Marshal

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

func (*ConfigItem) MarshalTo

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

func (*ConfigItem) MarshalToSizedBuffer

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

func (*ConfigItem) ProtoMessage

func (*ConfigItem) ProtoMessage()

func (*ConfigItem) Reset

func (m *ConfigItem) Reset()

func (*ConfigItem) Size

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

func (*ConfigItem) String

func (m *ConfigItem) String() string

func (*ConfigItem) Unmarshal

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

func (*ConfigItem) XXX_DiscardUnknown

func (m *ConfigItem) XXX_DiscardUnknown()

func (*ConfigItem) XXX_Marshal

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

func (*ConfigItem) XXX_Merge

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

func (*ConfigItem) XXX_Size

func (m *ConfigItem) XXX_Size() int

func (*ConfigItem) XXX_Unmarshal

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

type PluginTask

type PluginTask struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Data                 string   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	Token                string   `protobuf:"bytes,3,opt,name=Token,proto3" json:"Token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PluginTask) Descriptor

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

func (*PluginTask) GetData

func (m *PluginTask) GetData() string

func (*PluginTask) GetName

func (m *PluginTask) GetName() string

func (*PluginTask) GetToken

func (m *PluginTask) GetToken() string

func (*PluginTask) Marshal

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

func (*PluginTask) MarshalTo

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

func (*PluginTask) MarshalToSizedBuffer

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

func (*PluginTask) ProtoMessage

func (*PluginTask) ProtoMessage()

func (*PluginTask) Reset

func (m *PluginTask) Reset()

func (*PluginTask) Size

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

func (*PluginTask) String

func (m *PluginTask) String() string

func (*PluginTask) Unmarshal

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

func (*PluginTask) XXX_DiscardUnknown

func (m *PluginTask) XXX_DiscardUnknown()

func (*PluginTask) XXX_Marshal

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

func (*PluginTask) XXX_Merge

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

func (*PluginTask) XXX_Size

func (m *PluginTask) XXX_Size() int

func (*PluginTask) XXX_Unmarshal

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

type RawData

type RawData struct {
	IntranetIPv4         []string  `protobuf:"bytes,1,rep,name=IntranetIPv4,proto3" json:"IntranetIPv4,omitempty"`
	ExtranetIPv4         []string  `protobuf:"bytes,2,rep,name=ExtranetIPv4,proto3" json:"ExtranetIPv4,omitempty"`
	IntranetIPv6         []string  `protobuf:"bytes,3,rep,name=IntranetIPv6,proto3" json:"IntranetIPv6,omitempty"`
	ExtranetIPv6         []string  `protobuf:"bytes,4,rep,name=ExtranetIPv6,proto3" json:"ExtranetIPv6,omitempty"`
	Hostname             string    `protobuf:"bytes,5,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	AgentID              string    `protobuf:"bytes,6,opt,name=AgentID,proto3" json:"AgentID,omitempty"`
	Timestamp            int64     `protobuf:"varint,7,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Version              string    `protobuf:"bytes,8,opt,name=Version,proto3" json:"Version,omitempty"`
	Pkg                  []*Record `protobuf:"bytes,9,rep,name=Pkg,proto3" json:"Pkg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

agent --> server

func (*RawData) Descriptor

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

func (*RawData) GetAgentID

func (m *RawData) GetAgentID() string

func (*RawData) GetExtranetIPv4

func (m *RawData) GetExtranetIPv4() []string

func (*RawData) GetExtranetIPv6

func (m *RawData) GetExtranetIPv6() []string

func (*RawData) GetHostname

func (m *RawData) GetHostname() string

func (*RawData) GetIntranetIPv4

func (m *RawData) GetIntranetIPv4() []string

func (*RawData) GetIntranetIPv6

func (m *RawData) GetIntranetIPv6() []string

func (*RawData) GetPkg

func (m *RawData) GetPkg() []*Record

func (*RawData) GetTimestamp

func (m *RawData) GetTimestamp() int64

func (*RawData) GetVersion

func (m *RawData) GetVersion() string

func (*RawData) Marshal

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

func (*RawData) MarshalTo

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

func (*RawData) MarshalToSizedBuffer

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

func (*RawData) ProtoMessage

func (*RawData) ProtoMessage()

func (*RawData) Reset

func (m *RawData) Reset()

func (*RawData) Size

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

func (*RawData) String

func (m *RawData) String() string

func (*RawData) Unmarshal

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

func (*RawData) XXX_DiscardUnknown

func (m *RawData) XXX_DiscardUnknown()

func (*RawData) XXX_Marshal

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

func (*RawData) XXX_Merge

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

func (*RawData) XXX_Size

func (m *RawData) XXX_Size() int

func (*RawData) XXX_Unmarshal

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

type Record

type Record struct {
	Message              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Record) Descriptor

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

func (*Record) GetMessage

func (m *Record) GetMessage() map[string]string

func (*Record) Marshal

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

func (*Record) MarshalTo

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

func (*Record) MarshalToSizedBuffer

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

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) Size

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

func (*Record) String

func (m *Record) String() string

func (*Record) Unmarshal

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

func (*Record) XXX_DiscardUnknown

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal

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

func (*Record) XXX_Merge

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

func (*Record) XXX_Size

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal

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

type TransferClient

type TransferClient interface {
	Transfer(ctx context.Context, opts ...grpc.CallOption) (Transfer_TransferClient, error)
}

TransferClient is the client API for Transfer service.

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

func NewTransferClient

func NewTransferClient(cc *grpc.ClientConn) TransferClient

type TransferServer

type TransferServer interface {
	Transfer(Transfer_TransferServer) error
}

TransferServer is the server API for Transfer service.

type Transfer_TransferClient

type Transfer_TransferClient interface {
	Send(*RawData) error
	Recv() (*Command, error)
	grpc.ClientStream
}

type Transfer_TransferServer

type Transfer_TransferServer interface {
	Send(*Command) error
	Recv() (*RawData, error)
	grpc.ServerStream
}

type UnimplementedTransferServer

type UnimplementedTransferServer struct {
}

UnimplementedTransferServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransferServer) Transfer

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL