proto

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 FileUploadResponse_StatusCode_name = map[int32]string{
	0: "SUCCESS",
	1: "FAILED",
}
View Source 
var FileUploadResponse_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 {
	Ctrl    int32     `protobuf:"varint,1,opt,name=ctrl,proto3" json:"ctrl,omitempty"`
	Task    *Task     `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Configs []*Config `protobuf:"bytes,3,rep,name=configs,proto3" json:"configs,omitempty"`
}

func (*Command) Descriptor 

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

func (*Command) GetConfigs 

func (m *Command) GetConfigs() []*Config

func (*Command) GetCtrl 

func (m *Command) GetCtrl() int32

func (*Command) GetTask 

func (m *Command) GetTask() *Task

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 Config 

type Config 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"`
	DownloadUrls []string `protobuf:"bytes,6,rep,name=download_urls,json=downloadUrls,proto3" json:"download_urls,omitempty"`
	Detail       string   `protobuf:"bytes,7,opt,name=detail,proto3" json:"detail,omitempty"`
}

func (*Config) Descriptor 

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

func (*Config) GetDetail 

func (m *Config) GetDetail() string

func (*Config) GetDownloadUrls 

func (m *Config) GetDownloadUrls() []string

func (*Config) GetName 

func (m *Config) GetName() string

func (*Config) GetSha256 

func (m *Config) GetSha256() string

func (*Config) GetSignature 

func (m *Config) GetSignature() string

func (*Config) GetType 

func (m *Config) GetType() string

func (*Config) GetVersion 

func (m *Config) GetVersion() string

func (*Config) Marshal 

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

func (*Config) MarshalTo 

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

func (*Config) MarshalToSizedBuffer 

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

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (m *Config) Reset()

func (*Config) Size 

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

func (*Config) String 

func (m *Config) String() string

func (*Config) Unmarshal 

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

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

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

func (*Config) XXX_Merge 

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

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

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

type EncodedRecord 

type EncodedRecord struct {
	DataType  int32  `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*EncodedRecord) Descriptor 

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

func (*EncodedRecord) GetData 

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

func (*EncodedRecord) GetDataType 

func (m *EncodedRecord) GetDataType() int32

func (*EncodedRecord) GetTimestamp 

func (m *EncodedRecord) GetTimestamp() int64

func (*EncodedRecord) Marshal 

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

func (*EncodedRecord) MarshalTo 

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

func (*EncodedRecord) MarshalToSizedBuffer 

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

func (*EncodedRecord) ProtoMessage 

func (*EncodedRecord) ProtoMessage()

func (*EncodedRecord) Reset 

func (m *EncodedRecord) Reset()

func (*EncodedRecord) Size 

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

func (*EncodedRecord) String 

func (m *EncodedRecord) String() string

func (*EncodedRecord) Unmarshal 

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

func (*EncodedRecord) XXX_DiscardUnknown 

func (m *EncodedRecord) XXX_DiscardUnknown()

func (*EncodedRecord) XXX_Marshal 

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

func (*EncodedRecord) XXX_Merge 

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

func (*EncodedRecord) XXX_Size 

func (m *EncodedRecord) XXX_Size() int

func (*EncodedRecord) XXX_Unmarshal 

func (m *EncodedRecord) 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(*FileUploadRequest) error
	CloseAndRecv() (*FileUploadResponse, error)
	grpc.ClientStream
}

type FileExt_UploadServer 

type FileExt_UploadServer interface {
	SendAndClose(*FileUploadResponse) error
	Recv() (*FileUploadRequest, error)
	grpc.ServerStream
}

type FileUploadRequest 

type FileUploadRequest 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"`
}

func (*FileUploadRequest) Descriptor 

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

func (*FileUploadRequest) GetData 

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

func (*FileUploadRequest) GetToken 

func (m *FileUploadRequest) GetToken() string

func (*FileUploadRequest) Marshal 

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

func (*FileUploadRequest) MarshalTo 

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

func (*FileUploadRequest) MarshalToSizedBuffer 

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

func (*FileUploadRequest) ProtoMessage 

func (*FileUploadRequest) ProtoMessage()

func (*FileUploadRequest) Reset 

func (m *FileUploadRequest) Reset()

func (*FileUploadRequest) Size 

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

func (*FileUploadRequest) String 

func (m *FileUploadRequest) String() string

func (*FileUploadRequest) Unmarshal 

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

func (*FileUploadRequest) XXX_DiscardUnknown 

func (m *FileUploadRequest) XXX_DiscardUnknown()

func (*FileUploadRequest) XXX_Marshal 

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

func (*FileUploadRequest) XXX_Merge 

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

func (*FileUploadRequest) XXX_Size 

func (m *FileUploadRequest) XXX_Size() int

func (*FileUploadRequest) XXX_Unmarshal 

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

type FileUploadResponse 

type FileUploadResponse struct {
	Status FileUploadResponse_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=grpc.FileUploadResponse_StatusCode" json:"status,omitempty"`
}

func (*FileUploadResponse) Descriptor 

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

func (*FileUploadResponse) GetStatus 

func (m *FileUploadResponse) GetStatus() FileUploadResponse_StatusCode

func (*FileUploadResponse) Marshal 

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

func (*FileUploadResponse) MarshalTo 

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

func (*FileUploadResponse) MarshalToSizedBuffer 

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

func (*FileUploadResponse) ProtoMessage 

func (*FileUploadResponse) ProtoMessage()

func (*FileUploadResponse) Reset 

func (m *FileUploadResponse) Reset()

func (*FileUploadResponse) Size 

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

func (*FileUploadResponse) String 

func (m *FileUploadResponse) String() string

func (*FileUploadResponse) Unmarshal 

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

func (*FileUploadResponse) XXX_DiscardUnknown 

func (m *FileUploadResponse) XXX_DiscardUnknown()

func (*FileUploadResponse) XXX_Marshal 

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

func (*FileUploadResponse) XXX_Merge 

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

func (*FileUploadResponse) XXX_Size 

func (m *FileUploadResponse) XXX_Size() int

func (*FileUploadResponse) XXX_Unmarshal 

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

type FileUploadResponse_StatusCode 

type FileUploadResponse_StatusCode int32
const (
	FileUploadResponse_SUCCESS FileUploadResponse_StatusCode = 0
	FileUploadResponse_FAILED  FileUploadResponse_StatusCode = 1
)

func (FileUploadResponse_StatusCode) EnumDescriptor 

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

func (FileUploadResponse_StatusCode) String 

func (x FileUploadResponse_StatusCode) String() string

type PackagedData 

type PackagedData struct {
	Records      []*EncodedRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	AgentId      string           `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	IntranetIpv4 []string         `protobuf:"bytes,3,rep,name=intranet_ipv4,json=intranetIpv4,proto3" json:"intranet_ipv4,omitempty"`
	ExtranetIpv4 []string         `protobuf:"bytes,4,rep,name=extranet_ipv4,json=extranetIpv4,proto3" json:"extranet_ipv4,omitempty"`
	IntranetIpv6 []string         `protobuf:"bytes,5,rep,name=intranet_ipv6,json=intranetIpv6,proto3" json:"intranet_ipv6,omitempty"`
	ExtranetIpv6 []string         `protobuf:"bytes,6,rep,name=extranet_ipv6,json=extranetIpv6,proto3" json:"extranet_ipv6,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"`
}

func (*PackagedData) Descriptor 

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

func (*PackagedData) GetAgentId 

func (m *PackagedData) GetAgentId() string

func (*PackagedData) GetExtranetIpv4 

func (m *PackagedData) GetExtranetIpv4() []string

func (*PackagedData) GetExtranetIpv6 

func (m *PackagedData) GetExtranetIpv6() []string

func (*PackagedData) GetHostname 

func (m *PackagedData) GetHostname() string

func (*PackagedData) GetIntranetIpv4 

func (m *PackagedData) GetIntranetIpv4() []string

func (*PackagedData) GetIntranetIpv6 

func (m *PackagedData) GetIntranetIpv6() []string

func (*PackagedData) GetProduct 

func (m *PackagedData) GetProduct() string

func (*PackagedData) GetRecords 

func (m *PackagedData) GetRecords() []*EncodedRecord

func (*PackagedData) GetVersion 

func (m *PackagedData) GetVersion() string

func (*PackagedData) Marshal 

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

func (*PackagedData) MarshalTo 

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

func (*PackagedData) MarshalToSizedBuffer 

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

func (*PackagedData) ProtoMessage 

func (*PackagedData) ProtoMessage()

func (*PackagedData) Reset 

func (m *PackagedData) Reset()

func (*PackagedData) Size 

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

func (*PackagedData) String 

func (m *PackagedData) String() string

func (*PackagedData) Unmarshal 

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

func (*PackagedData) XXX_DiscardUnknown 

func (m *PackagedData) XXX_DiscardUnknown()

func (*PackagedData) XXX_Marshal 

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

func (*PackagedData) XXX_Merge 

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

func (*PackagedData) XXX_Size 

func (m *PackagedData) XXX_Size() int

func (*PackagedData) XXX_Unmarshal 

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

type Payload 

type Payload struct {
	Fields map[string]string `` /* 153-byte string literal not displayed */
}

func (*Payload) Descriptor 

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

func (*Payload) GetFields 

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

func (*Payload) Marshal 

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

func (*Payload) MarshalTo 

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

func (*Payload) MarshalToSizedBuffer 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

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

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type Record 

type Record struct {
	DataType  int32    `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	Timestamp int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Data      *Payload `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Record) Descriptor 

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

func (*Record) GetData 

func (m *Record) GetData() *Payload

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 Task 

type Task struct {
	DataType   int32  `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	ObjectName string `protobuf:"bytes,2,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	Data       string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Token      string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
}

func (*Task) Descriptor 

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

func (*Task) GetData 

func (m *Task) GetData() string

func (*Task) GetDataType 

func (m *Task) GetDataType() int32

func (*Task) GetObjectName 

func (m *Task) GetObjectName() string

func (*Task) GetToken 

func (m *Task) GetToken() string

func (*Task) Marshal 

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

func (*Task) MarshalTo 

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

func (*Task) MarshalToSizedBuffer 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

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

func (*Task) String 

func (m *Task) String() string

func (*Task) Unmarshal 

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

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

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

func (*Task) XXX_Merge 

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

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

func (m *Task) 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(*PackagedData) error
	Recv() (*Command, error)
	grpc.ClientStream
}

type Transfer_TransferServer 

type Transfer_TransferServer interface {
	Send(*Command) error
	Recv() (*PackagedData, 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

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.