regproto

package
v0.0.0-...-3f995bb Latest Latest
Warning

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

Go to latest
Published: Aug 18, 2016 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package regproto is a generated protocol buffer package.

It is generated from these files:

registry.proto

It has these top-level messages:

Chunk
Received

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRegistryServer

func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)

Types

type Chunk

type Chunk struct {
	// TODO AuthToken auth = 1;
	FileType string `protobuf:"bytes,1,opt,name=file_type,json=fileType" json:"file_type,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

Chunk of a file

func (*Chunk) Descriptor

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

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) String

func (m *Chunk) String() string

type Received

type Received struct {
	Received bool `protobuf:"varint,1,opt,name=received" json:"received,omitempty"`
}

Acknowledgement - maybe stream this for partial upload recovery Do we need this or can we just use gRPC errors?

func (*Received) Descriptor

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

func (*Received) ProtoMessage

func (*Received) ProtoMessage()

func (*Received) Reset

func (m *Received) Reset()

func (*Received) String

func (m *Received) String() string

type RegistryClient

type RegistryClient interface {
	Push(ctx context.Context, opts ...grpc.CallOption) (Registry_PushClient, error)
}

func NewRegistryClient

func NewRegistryClient(cc *grpc.ClientConn) RegistryClient

type RegistryServer

type RegistryServer interface {
	Push(Registry_PushServer) error
}

type Registry_PushClient

type Registry_PushClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*Received, error)
	grpc.ClientStream
}

type Registry_PushServer

type Registry_PushServer interface {
	SendAndClose(*Received) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

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