pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

mokoshsvc.proto

It has these top-level messages:

CapabilitiesRequest
CapabilitiesReply
MergePart
MergeResult

Index

• Variables
• func RegisterMokoshServer(s *grpc.Server, srv MokoshServer)
• type CapabilitiesReply
  • func (*CapabilitiesReply) Descriptor() ([]byte, []int)
  • func (m *CapabilitiesReply) GetCapabilities() []Capability
  • func (*CapabilitiesReply) ProtoMessage()
  • func (m *CapabilitiesReply) Reset()
  • func (m *CapabilitiesReply) String() string
• type CapabilitiesRequest
  • func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
  • func (*CapabilitiesRequest) ProtoMessage()
  • func (m *CapabilitiesRequest) Reset()
  • func (m *CapabilitiesRequest) String() string
• type Capability
  • func (Capability) EnumDescriptor() ([]byte, []int)
  • func (x Capability) String() string
• type MergePart
  • func (*MergePart) Descriptor() ([]byte, []int)
  • func (m *MergePart) GetAddEmptyIfOdd() bool
  • func (m *MergePart) GetData() []byte
  • func (*MergePart) ProtoMessage()
  • func (m *MergePart) Reset()
  • func (m *MergePart) String() string
• type MergeResult
  • func (*MergeResult) Descriptor() ([]byte, []int)
  • func (m *MergeResult) GetData() []byte
  • func (m *MergeResult) GetPages() int32
  • func (*MergeResult) ProtoMessage()
  • func (m *MergeResult) Reset()
  • func (m *MergeResult) String() string
• type MokoshClient
  • func NewMokoshClient(cc *grpc.ClientConn) MokoshClient
• type MokoshServer
• type Mokosh_MergeClient
• type Mokosh_MergeServer

Variables

var Capability_name = map[int32]string{
	0: "MERGE",
}

var Capability_value = map[string]int32{
	"MERGE": 0,
}

Functions

func RegisterMokoshServer

func RegisterMokoshServer(s *grpc.Server, srv MokoshServer)

Types

type CapabilitiesReply

type CapabilitiesReply struct {
	Capabilities []Capability `protobuf:"varint,1,rep,packed,name=capabilities,enum=pb.Capability" json:"capabilities,omitempty"`
}

The response message containing capabilites of this server

func (*CapabilitiesReply) Descriptor

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

func (*CapabilitiesReply) GetCapabilities

func (m *CapabilitiesReply) GetCapabilities() []Capability

func (*CapabilitiesReply) ProtoMessage

func (*CapabilitiesReply) ProtoMessage()

func (*CapabilitiesReply) Reset

func (m *CapabilitiesReply) Reset()

func (*CapabilitiesReply) String

func (m *CapabilitiesReply) String() string

type CapabilitiesRequest

type CapabilitiesRequest struct {
}

The request message

func (*CapabilitiesRequest) Descriptor

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

func (*CapabilitiesRequest) ProtoMessage

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) Reset

func (m *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) String

func (m *CapabilitiesRequest) String() string

type Capability

type Capability int32

const (
	Capability_MERGE Capability = 0
)

func (Capability) EnumDescriptor

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

func (Capability) String

func (x Capability) String() string

type MergePart

type MergePart struct {
	Data          []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	AddEmptyIfOdd bool   `protobuf:"varint,2,opt,name=addEmptyIfOdd" json:"addEmptyIfOdd,omitempty"`
}

func (*MergePart) Descriptor

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

func (*MergePart) GetAddEmptyIfOdd

func (m *MergePart) GetAddEmptyIfOdd() bool

func (*MergePart) GetData

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

func (*MergePart) ProtoMessage

func (*MergePart) ProtoMessage()

func (*MergePart) Reset

func (m *MergePart) Reset()

func (*MergePart) String

func (m *MergePart) String() string

type MergeResult

type MergeResult struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Pages int32  `protobuf:"varint,2,opt,name=pages" json:"pages,omitempty"`
}

func (*MergeResult) Descriptor

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

func (*MergeResult) GetData

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

func (*MergeResult) GetPages

func (m *MergeResult) GetPages() int32

func (*MergeResult) ProtoMessage

func (*MergeResult) ProtoMessage()

func (*MergeResult) Reset

func (m *MergeResult) Reset()

func (*MergeResult) String

func (m *MergeResult) String() string

type MokoshClient

type MokoshClient interface {
	// Request all capabilities supported by this instance
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesReply, error)
	Merge(ctx context.Context, opts ...grpc.CallOption) (Mokosh_MergeClient, error)
}

func NewMokoshClient

func NewMokoshClient(cc *grpc.ClientConn) MokoshClient

type MokoshServer

type MokoshServer interface {
	// Request all capabilities supported by this instance
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesReply, error)
	Merge(Mokosh_MergeServer) error
}

type Mokosh_MergeClient

type Mokosh_MergeClient interface {
	Send(*MergePart) error
	CloseAndRecv() (*MergeResult, error)
	grpc.ClientStream
}

type Mokosh_MergeServer

type Mokosh_MergeServer interface {
	SendAndClose(*MergeResult) error
	Recv() (*MergePart, error)
	grpc.ServerStream
}