grpc

package
v0.0.0-...-ecc5721 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGrpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGrpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var UploadResponse_StatusCode_name = map[int32]string{
	0: "SUCCESS",
	1: "FAILED",
}
View Source 
var UploadResponse_StatusCode_value = map[string]int32{
	"SUCCESS": 0,
	"FAILED":  1,
}

Functions

func RegisterFileExtServer 

func RegisterFileExtServer(s *grpc.Server, srv FileExtServer)

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"`
	Type                 string   `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
	Version              string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	SHA256               string   `protobuf:"bytes,4,opt,name=SHA256,proto3" json:"SHA256,omitempty"`
	Signature            string   `protobuf:"bytes,5,opt,name=Signature,proto3" json:"Signature,omitempty"`
	DownloadURL          []string `protobuf:"bytes,6,rep,name=DownloadURL,proto3" json:"DownloadURL,omitempty"`
	Detail               string   `protobuf:"bytes,7,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) GetSignature 

func (m *ConfigItem) GetSignature() string

func (*ConfigItem) GetType 

func (m *ConfigItem) GetType() 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 FileExtClient 

type FileExtClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (FileExt_UploadClient, error)
}

FileExtClient is the client API for FileExt service.

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

func NewFileExtClient 

func NewFileExtClient(cc *grpc.ClientConn) FileExtClient

type FileExtServer 

type FileExtServer interface {
	Upload(FileExt_UploadServer) error
}

FileExtServer is the server API for FileExt service.

type FileExt_UploadClient 

type FileExt_UploadClient interface {
	Send(*UploadRequest) error
	CloseAndRecv() (*UploadResponse, error)
	grpc.ClientStream
}

type FileExt_UploadServer 

type FileExt_UploadServer interface {
	SendAndClose(*UploadResponse) error
	Recv() (*UploadRequest, error)
	grpc.ServerStream
}

type Item 

type Item struct {
	Fields               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Item) Descriptor 

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

func (*Item) GetFields 

func (m *Item) GetFields() map[string]string

func (*Item) Marshal 

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

func (*Item) MarshalTo 

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

func (*Item) MarshalToSizedBuffer 

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

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) Reset 

func (m *Item) Reset()

func (*Item) Size 

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

func (*Item) String 

func (m *Item) String() string

func (*Item) Unmarshal 

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

func (*Item) XXX_DiscardUnknown 

func (m *Item) XXX_DiscardUnknown()

func (*Item) XXX_Marshal 

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

func (*Item) XXX_Merge 

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

func (*Item) XXX_Size 

func (m *Item) XXX_Size() int

func (*Item) XXX_Unmarshal 

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

type MQData 

type MQData struct {
	DataType     int32  `protobuf:"varint,1,opt,name=DataType,proto3" json:"DataType,omitempty"`
	AgentTime    int64  `protobuf:"varint,2,opt,name=AgentTime,proto3" json:"AgentTime,omitempty"`
	Body         []byte `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	AgentID      string `protobuf:"bytes,4,opt,name=AgentID,proto3" json:"AgentID,omitempty"`
	IntranetIPv4 string `protobuf:"bytes,5,opt,name=IntranetIPv4,proto3" json:"IntranetIPv4,omitempty"`
	ExtranetIPv4 string `protobuf:"bytes,6,opt,name=ExtranetIPv4,proto3" json:"ExtranetIPv4,omitempty"`
	IntranetIPv6 string `protobuf:"bytes,7,opt,name=IntranetIPv6,proto3" json:"IntranetIPv6,omitempty"`
	ExtranetIPv6 string `protobuf:"bytes,8,opt,name=ExtranetIPv6,proto3" json:"ExtranetIPv6,omitempty"`
	Hostname     string `protobuf:"bytes,9,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Version      string `protobuf:"bytes,10,opt,name=Version,proto3" json:"Version,omitempty"`
	Product      string `protobuf:"bytes,11,opt,name=Product,proto3" json:"Product,omitempty"`
	//Fields completed on the server
	SvrTime              int64    `protobuf:"varint,12,opt,name=SvrTime,proto3" json:"SvrTime,omitempty"`
	PSMName              string   `protobuf:"bytes,13,opt,name=PSMName,proto3" json:"PSMName,omitempty"`
	PSMPath              string   `protobuf:"bytes,14,opt,name=PSMPath,proto3" json:"PSMPath,omitempty"`
	Tag                  string   `protobuf:"bytes,15,opt,name=Tag,proto3" json:"Tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

server -> bmq

func (*MQData) Descriptor 

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

func (*MQData) GetAgentID 

func (m *MQData) GetAgentID() string

func (*MQData) GetAgentTime 

func (m *MQData) GetAgentTime() int64

func (*MQData) GetBody 

func (m *MQData) GetBody() []byte

func (*MQData) GetDataType 

func (m *MQData) GetDataType() int32

func (*MQData) GetExtranetIPv4 

func (m *MQData) GetExtranetIPv4() string

func (*MQData) GetExtranetIPv6 

func (m *MQData) GetExtranetIPv6() string

func (*MQData) GetHostname 

func (m *MQData) GetHostname() string

func (*MQData) GetIntranetIPv4 

func (m *MQData) GetIntranetIPv4() string

func (*MQData) GetIntranetIPv6 

func (m *MQData) GetIntranetIPv6() string

func (*MQData) GetPSMName 

func (m *MQData) GetPSMName() string

func (*MQData) GetPSMPath 

func (m *MQData) GetPSMPath() string

func (*MQData) GetProduct 

func (m *MQData) GetProduct() string

func (*MQData) GetSvrTime 

func (m *MQData) GetSvrTime() int64

func (*MQData) GetTag 

func (m *MQData) GetTag() string

func (*MQData) GetVersion 

func (m *MQData) GetVersion() string

func (*MQData) Marshal 

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

func (*MQData) MarshalTo 

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

func (*MQData) MarshalToSizedBuffer 

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

func (*MQData) ProtoMessage 

func (*MQData) ProtoMessage()

func (*MQData) Reset 

func (m *MQData) Reset()

func (*MQData) Size 

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

func (*MQData) String 

func (m *MQData) String() string

func (*MQData) Unmarshal 

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

func (*MQData) XXX_DiscardUnknown 

func (m *MQData) XXX_DiscardUnknown()

func (*MQData) XXX_Marshal 

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

func (*MQData) XXX_Merge 

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

func (*MQData) XXX_Size 

func (m *MQData) XXX_Size() int

func (*MQData) XXX_Unmarshal 

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

type MQRawData 

type MQRawData struct {
	DataType     int32  `protobuf:"varint,1,opt,name=DataType,proto3" json:"DataType,omitempty"`
	AgentTime    int64  `protobuf:"varint,2,opt,name=AgentTime,proto3" json:"AgentTime,omitempty"`
	Body         *Item  `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	AgentID      string `protobuf:"bytes,4,opt,name=AgentID,proto3" json:"AgentID,omitempty"`
	IntranetIPv4 string `protobuf:"bytes,5,opt,name=IntranetIPv4,proto3" json:"IntranetIPv4,omitempty"`
	ExtranetIPv4 string `protobuf:"bytes,6,opt,name=ExtranetIPv4,proto3" json:"ExtranetIPv4,omitempty"`
	IntranetIPv6 string `protobuf:"bytes,7,opt,name=IntranetIPv6,proto3" json:"IntranetIPv6,omitempty"`
	ExtranetIPv6 string `protobuf:"bytes,8,opt,name=ExtranetIPv6,proto3" json:"ExtranetIPv6,omitempty"`
	Hostname     string `protobuf:"bytes,9,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Version      string `protobuf:"bytes,10,opt,name=Version,proto3" json:"Version,omitempty"`
	Product      string `protobuf:"bytes,11,opt,name=Product,proto3" json:"Product,omitempty"`
	//Fields completed on the server
	SvrTime              int64    `protobuf:"varint,12,opt,name=SvrTime,proto3" json:"SvrTime,omitempty"`
	PSMName              string   `protobuf:"bytes,13,opt,name=PSMName,proto3" json:"PSMName,omitempty"`
	PSMPath              string   `protobuf:"bytes,14,opt,name=PSMPath,proto3" json:"PSMPath,omitempty"`
	Tags                 string   `protobuf:"bytes,15,opt,name=Tags,proto3" json:"Tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

bmq --> Rule engine

func (*MQRawData) Descriptor 

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

func (*MQRawData) GetAgentID 

func (m *MQRawData) GetAgentID() string

func (*MQRawData) GetAgentTime 

func (m *MQRawData) GetAgentTime() int64

func (*MQRawData) GetBody 

func (m *MQRawData) GetBody() *Item

func (*MQRawData) GetDataType 

func (m *MQRawData) GetDataType() int32

func (*MQRawData) GetExtranetIPv4 

func (m *MQRawData) GetExtranetIPv4() string

func (*MQRawData) GetExtranetIPv6 

func (m *MQRawData) GetExtranetIPv6() string

func (*MQRawData) GetHostname 

func (m *MQRawData) GetHostname() string

func (*MQRawData) GetIntranetIPv4 

func (m *MQRawData) GetIntranetIPv4() string

func (*MQRawData) GetIntranetIPv6 

func (m *MQRawData) GetIntranetIPv6() string

func (*MQRawData) GetPSMName 

func (m *MQRawData) GetPSMName() string

func (*MQRawData) GetPSMPath 

func (m *MQRawData) GetPSMPath() string

func (*MQRawData) GetProduct 

func (m *MQRawData) GetProduct() string

func (*MQRawData) GetSvrTime 

func (m *MQRawData) GetSvrTime() int64

func (*MQRawData) GetTags 

func (m *MQRawData) GetTags() string

func (*MQRawData) GetVersion 

func (m *MQRawData) GetVersion() string

func (*MQRawData) Marshal 

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

func (*MQRawData) MarshalTo 

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

func (*MQRawData) MarshalToSizedBuffer 

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

func (*MQRawData) ProtoMessage 

func (*MQRawData) ProtoMessage()

func (*MQRawData) Reset 

func (m *MQRawData) Reset()

func (*MQRawData) Size 

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

func (*MQRawData) String 

func (m *MQRawData) String() string

func (*MQRawData) Unmarshal 

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

func (*MQRawData) XXX_DiscardUnknown 

func (m *MQRawData) XXX_DiscardUnknown()

func (*MQRawData) XXX_Marshal 

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

func (*MQRawData) XXX_Merge 

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

func (*MQRawData) XXX_Size 

func (m *MQRawData) XXX_Size() int

func (*MQRawData) XXX_Unmarshal 

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

type PluginTask 

type PluginTask struct {
	//DataType which used to uniquely identify different  format of Data
	DataType int32 `protobuf:"varint,1,opt,name=DataType,proto3" json:"DataType,omitempty"`
	// Plugin name, which used to uniquely identify different plugins
	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// Data transparently transmitted to the plugin
	Data string `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// The token is used for reconciliation
	Token                string   `protobuf:"bytes,4,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) GetDataType 

func (m *PluginTask) GetDataType() int32

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 {
	Data                 []*Record `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	AgentID              string    `protobuf:"bytes,2,opt,name=AgentID,proto3" json:"AgentID,omitempty"`
	IntranetIPv4         []string  `protobuf:"bytes,3,rep,name=IntranetIPv4,proto3" json:"IntranetIPv4,omitempty"`
	ExtranetIPv4         []string  `protobuf:"bytes,4,rep,name=ExtranetIPv4,proto3" json:"ExtranetIPv4,omitempty"`
	IntranetIPv6         []string  `protobuf:"bytes,5,rep,name=IntranetIPv6,proto3" json:"IntranetIPv6,omitempty"`
	ExtranetIPv6         []string  `protobuf:"bytes,6,rep,name=ExtranetIPv6,proto3" json:"ExtranetIPv6,omitempty"`
	Hostname             string    `protobuf:"bytes,7,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Version              string    `protobuf:"bytes,8,opt,name=Version,proto3" json:"Version,omitempty"`
	Product              string    `protobuf:"bytes,9,opt,name=Product,proto3" json:"Product,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

pb for rawdata agent --> server

func (*RawData) Descriptor 

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

func (*RawData) GetAgentID 

func (m *RawData) GetAgentID() string

func (*RawData) GetData 

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

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

func (m *RawData) GetProduct() string

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 {
	DataType             int32    `protobuf:"varint,1,opt,name=DataType,proto3" json:"DataType,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Body                 []byte   `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Record) Descriptor 

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

func (*Record) GetBody 

func (m *Record) GetBody() []byte

func (*Record) GetDataType 

func (m *Record) GetDataType() int32

func (*Record) GetTimestamp 

func (m *Record) GetTimestamp() int64

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 UnimplementedFileExtServer 

type UnimplementedFileExtServer struct {
}

UnimplementedFileExtServer can be embedded to have forward compatible implementations.

func (*UnimplementedFileExtServer) Upload 

func (*UnimplementedFileExtServer) Upload(srv FileExt_UploadServer) error

type UnimplementedTransferServer 

type UnimplementedTransferServer struct {
}

UnimplementedTransferServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransferServer) Transfer 

func (*UnimplementedTransferServer) Transfer(srv Transfer_TransferServer) error

type UploadRequest 

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

pb for file upload

func (*UploadRequest) Descriptor 

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

func (*UploadRequest) GetData 

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

func (*UploadRequest) GetToken 

func (m *UploadRequest) GetToken() string

func (*UploadRequest) Marshal 

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

func (*UploadRequest) MarshalTo 

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

func (*UploadRequest) MarshalToSizedBuffer 

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

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) Reset 

func (m *UploadRequest) Reset()

func (*UploadRequest) Size 

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

func (*UploadRequest) String 

func (m *UploadRequest) String() string

func (*UploadRequest) Unmarshal 

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

func (*UploadRequest) XXX_DiscardUnknown 

func (m *UploadRequest) XXX_DiscardUnknown()

func (*UploadRequest) XXX_Marshal 

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

func (*UploadRequest) XXX_Merge 

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

func (*UploadRequest) XXX_Size 

func (m *UploadRequest) XXX_Size() int

func (*UploadRequest) XXX_Unmarshal 

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

type UploadResponse 

type UploadResponse struct {
	Status               UploadResponse_StatusCode `protobuf:"varint,1,opt,name=Status,proto3,enum=grpc.UploadResponse_StatusCode" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*UploadResponse) Descriptor 

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

func (*UploadResponse) GetStatus 

func (m *UploadResponse) GetStatus() UploadResponse_StatusCode

func (*UploadResponse) Marshal 

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

func (*UploadResponse) MarshalTo 

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

func (*UploadResponse) MarshalToSizedBuffer 

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

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) Reset 

func (m *UploadResponse) Reset()

func (*UploadResponse) Size 

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

func (*UploadResponse) String 

func (m *UploadResponse) String() string

func (*UploadResponse) Unmarshal 

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

func (*UploadResponse) XXX_DiscardUnknown 

func (m *UploadResponse) XXX_DiscardUnknown()

func (*UploadResponse) XXX_Marshal 

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

func (*UploadResponse) XXX_Merge 

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

func (*UploadResponse) XXX_Size 

func (m *UploadResponse) XXX_Size() int

func (*UploadResponse) XXX_Unmarshal 

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

type UploadResponse_StatusCode 

type UploadResponse_StatusCode int32
const (
	UploadResponse_SUCCESS UploadResponse_StatusCode = 0
	UploadResponse_FAILED  UploadResponse_StatusCode = 1
)

func (UploadResponse_StatusCode) EnumDescriptor 

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

func (UploadResponse_StatusCode) String 

func (x UploadResponse_StatusCode) String() string

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.