trace

package
v0.0.0-...-7760e95 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataCenterServer

func RegisterDataCenterServer(s *grpc.Server, srv DataCenterServer)

Types

type DataCenterClient

type DataCenterClient interface {
	SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	Download(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (DataCenter_DownloadClient, error)
	Upload(ctx context.Context, opts ...grpc.CallOption) (DataCenter_UploadClient, error)
}

DataCenterClient is the client API for DataCenter service.

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

func NewDataCenterClient

func NewDataCenterClient(cc grpc.ClientConnInterface) DataCenterClient

type DataCenterServer

type DataCenterServer interface {
	SayHello(context.Context, *HelloRequest) (*HelloResponse, error)
	Download(*empty.Empty, DataCenter_DownloadServer) error
	Upload(DataCenter_UploadServer) error
}

DataCenterServer is the server API for DataCenter service.

type DataCenter_DownloadClient

type DataCenter_DownloadClient interface {
	Recv() (*Packet, error)
	grpc.ClientStream
}

type DataCenter_DownloadServer

type DataCenter_DownloadServer interface {
	Send(*Packet) error
	grpc.ServerStream
}

type DataCenter_UploadClient

type DataCenter_UploadClient interface {
	Send(*Packet) error
	CloseAndRecv() (*UploadResult, error)
	grpc.ClientStream
}

type DataCenter_UploadServer

type DataCenter_UploadServer interface {
	SendAndClose(*UploadResult) error
	Recv() (*Packet, error)
	grpc.ServerStream
}

type HelloRequest

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

func (*HelloRequest) Descriptor

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

func (*HelloRequest) GetName

func (m *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset

func (m *HelloRequest) Reset()

func (*HelloRequest) String

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal

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

func (*HelloRequest) XXX_Merge

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

func (*HelloRequest) XXX_Size

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal

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

type HelloResponse

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

func (*HelloResponse) Descriptor

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

func (*HelloResponse) GetMessage

func (m *HelloResponse) GetMessage() string

func (*HelloResponse) ProtoMessage

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset

func (m *HelloResponse) Reset()

func (*HelloResponse) String

func (m *HelloResponse) String() string

func (*HelloResponse) XXX_DiscardUnknown

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal

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

func (*HelloResponse) XXX_Merge

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

func (*HelloResponse) XXX_Size

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal

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

type Packet

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

func (*Packet) Descriptor

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

func (*Packet) GetData

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

func (*Packet) ProtoMessage

func (*Packet) ProtoMessage()

func (*Packet) Reset

func (m *Packet) Reset()

func (*Packet) String

func (m *Packet) String() string

func (*Packet) XXX_DiscardUnknown

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal

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

func (*Packet) XXX_Merge

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

func (*Packet) XXX_Size

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal

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

type UnimplementedDataCenterServer

type UnimplementedDataCenterServer struct {
}

UnimplementedDataCenterServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataCenterServer) Download

func (*UnimplementedDataCenterServer) SayHello

func (*UnimplementedDataCenterServer) Upload

type UploadResult

type UploadResult struct {
	Size                 uint64   `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Checksum             []byte   `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UploadResult) Descriptor

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

func (*UploadResult) GetChecksum

func (m *UploadResult) GetChecksum() []byte

func (*UploadResult) GetSize

func (m *UploadResult) GetSize() uint64

func (*UploadResult) ProtoMessage

func (*UploadResult) ProtoMessage()

func (*UploadResult) Reset

func (m *UploadResult) Reset()

func (*UploadResult) String

func (m *UploadResult) String() string

func (*UploadResult) XXX_DiscardUnknown

func (m *UploadResult) XXX_DiscardUnknown()

func (*UploadResult) XXX_Marshal

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

func (*UploadResult) XXX_Merge

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

func (*UploadResult) XXX_Size

func (m *UploadResult) XXX_Size() int

func (*UploadResult) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL