proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

sink.proto

It has these top-level messages:

UploadRequest
Blob
UploadResponse

Index

• func RegisterSinkServer(s *grpc.Server, srv SinkServer)
• type Blob
  • func (*Blob) Descriptor() ([]byte, []int)
  • func (*Blob) ProtoMessage()
  • func (m *Blob) Reset()
  • func (m *Blob) String() string
• type SinkClient
  • func NewSinkClient(cc *grpc.ClientConn) SinkClient
• type SinkServer
• type UploadRequest
  • func (*UploadRequest) Descriptor() ([]byte, []int)
  • func (m *UploadRequest) GetBlob() []*Blob
  • func (*UploadRequest) ProtoMessage()
  • func (m *UploadRequest) Reset()
  • func (m *UploadRequest) String() string
• type UploadResponse
  • func (*UploadResponse) Descriptor() ([]byte, []int)
  • func (*UploadResponse) ProtoMessage()
  • func (m *UploadResponse) Reset()
  • func (m *UploadResponse) String() string

Functions

func RegisterSinkServer

func RegisterSinkServer(s *grpc.Server, srv SinkServer)

Types

type Blob

type Blob struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Blob) Descriptor

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

func (*Blob) ProtoMessage

func (*Blob) ProtoMessage()

func (*Blob) Reset

func (m *Blob) Reset()

func (*Blob) String

func (m *Blob) String() string

type SinkClient

type SinkClient interface {
	Upload(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)
}

func NewSinkClient

func NewSinkClient(cc *grpc.ClientConn) SinkClient

type SinkServer

type SinkServer interface {
	Upload(context.Context, *UploadRequest) (*UploadResponse, error)
}

type UploadRequest

type UploadRequest struct {
	Blob []*Blob `protobuf:"bytes,1,rep,name=blob" json:"blob,omitempty"`
}

func (*UploadRequest) Descriptor

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

func (*UploadRequest) GetBlob

func (m *UploadRequest) GetBlob() []*Blob

func (*UploadRequest) ProtoMessage

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) Reset

func (m *UploadRequest) Reset()

func (*UploadRequest) String

func (m *UploadRequest) String() string

type UploadResponse

type UploadResponse struct {
}

func (*UploadResponse) Descriptor

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

func (*UploadResponse) ProtoMessage

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) Reset

func (m *UploadResponse) Reset()

func (*UploadResponse) String

func (m *UploadResponse) String() string