blob

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var PushStatusCode_name = map[int32]string{
	0: "Unknown",
	1: "Ok",
	2: "Failed",
}
View Source 
var PushStatusCode_value = map[string]int32{
	"Unknown": 0,
	"Ok":      1,
	"Failed":  2,
}

Functions

func RegisterBlobServiceServer 

func RegisterBlobServiceServer(s *grpc.Server, srv BlobServiceServer)

Types

type BlobServiceClient 

type BlobServiceClient interface {
	Push(ctx context.Context, opts ...grpc.CallOption) (BlobService_PushClient, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (BlobService_GetClient, error)
}

BlobServiceClient is the client API for BlobService service.

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

func NewBlobServiceClient 

func NewBlobServiceClient(cc *grpc.ClientConn) BlobServiceClient

type BlobServiceServer 

type BlobServiceServer interface {
	Push(BlobService_PushServer) error
	Get(*GetRequest, BlobService_GetServer) error
}

BlobServiceServer is the server API for BlobService service.

type BlobService_GetClient 

type BlobService_GetClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type BlobService_GetServer 

type BlobService_GetServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type BlobService_PushClient 

type BlobService_PushClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*PushStatus, error)
	grpc.ClientStream
}

type BlobService_PushServer 

type BlobService_PushServer interface {
	SendAndClose(*PushStatus) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type Chunk 

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

func (*Chunk) Descriptor 

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

func (*Chunk) GetContent 

func (m *Chunk) GetContent() []byte

func (*Chunk) GetId 

func (m *Chunk) GetId() string

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type GetRequest 

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

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetId 

func (m *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type PushStatus 

type PushStatus struct {
	Message              string         `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Code                 PushStatusCode `protobuf:"varint,2,opt,name=Code,proto3,enum=PushStatusCode" json:"Code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PushStatus) Descriptor 

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

func (*PushStatus) GetCode 

func (m *PushStatus) GetCode() PushStatusCode

func (*PushStatus) GetMessage 

func (m *PushStatus) GetMessage() string

func (*PushStatus) ProtoMessage 

func (*PushStatus) ProtoMessage()

func (*PushStatus) Reset 

func (m *PushStatus) Reset()

func (*PushStatus) String 

func (m *PushStatus) String() string

func (*PushStatus) XXX_DiscardUnknown 

func (m *PushStatus) XXX_DiscardUnknown()

func (*PushStatus) XXX_Marshal 

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

func (*PushStatus) XXX_Merge 

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

func (*PushStatus) XXX_Size 

func (m *PushStatus) XXX_Size() int

func (*PushStatus) XXX_Unmarshal 

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

type PushStatusCode 

type PushStatusCode int32
const (
	PushStatusCode_Unknown PushStatusCode = 0
	PushStatusCode_Ok      PushStatusCode = 1
	PushStatusCode_Failed  PushStatusCode = 2
)

func (PushStatusCode) EnumDescriptor 

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

func (PushStatusCode) String 

func (x PushStatusCode) 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.