proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

value.proto

It has these top-level messages:

Update
Summary

Index

• func RegisterValueServiceServer(s *grpc.Server, srv ValueServiceServer)
• type Summary
  • func (*Summary) Descriptor() ([]byte, []int)
  • func (m *Summary) GetUpdates() int32
  • func (m *Summary) GetValue() int32
  • func (*Summary) ProtoMessage()
  • func (m *Summary) Reset()
  • func (m *Summary) String() string
• type Update
  • func (*Update) Descriptor() ([]byte, []int)
  • func (m *Update) GetDelta() int32
  • func (*Update) ProtoMessage()
  • func (m *Update) Reset()
  • func (m *Update) String() string
• type ValueServiceClient
  • func NewValueServiceClient(cc *grpc.ClientConn) ValueServiceClient
• type ValueServiceServer
• type ValueService_NoisyUpdateClient
• type ValueService_NoisyUpdateServer
• type ValueService_QuietUpdateClient
• type ValueService_QuietUpdateServer
• type ValueService_SubscribeClient
• type ValueService_SubscribeServer

Functions

func RegisterValueServiceServer

func RegisterValueServiceServer(s *grpc.Server, srv ValueServiceServer)

Types

type Summary

type Summary struct {
	Updates int32 `protobuf:"varint,1,opt,name=updates" json:"updates,omitempty"`
	Value   int32 `protobuf:"varint,2,opt,name=value" json:"value,omitempty"`
}

func (*Summary) Descriptor

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

func (*Summary) GetUpdates

func (m *Summary) GetUpdates() int32

func (*Summary) GetValue

func (m *Summary) GetValue() int32

func (*Summary) ProtoMessage

func (*Summary) ProtoMessage()

func (*Summary) Reset

func (m *Summary) Reset()

func (*Summary) String

func (m *Summary) String() string

type Update

type Update struct {
	Delta int32 `protobuf:"varint,1,opt,name=delta" json:"delta,omitempty"`
}

func (*Update) Descriptor

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

func (*Update) GetDelta

func (m *Update) GetDelta() int32

func (*Update) ProtoMessage

func (*Update) ProtoMessage()

func (*Update) Reset

func (m *Update) Reset()

func (*Update) String

func (m *Update) String() string

type ValueServiceClient

type ValueServiceClient interface {
	Subscribe(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (ValueService_SubscribeClient, error)
	QuietUpdate(ctx context.Context, opts ...grpc.CallOption) (ValueService_QuietUpdateClient, error)
	NoisyUpdate(ctx context.Context, opts ...grpc.CallOption) (ValueService_NoisyUpdateClient, error)
}

func NewValueServiceClient

func NewValueServiceClient(cc *grpc.ClientConn) ValueServiceClient

type ValueServiceServer

type ValueServiceServer interface {
	Subscribe(*google_protobuf.Empty, ValueService_SubscribeServer) error
	QuietUpdate(ValueService_QuietUpdateServer) error
	NoisyUpdate(ValueService_NoisyUpdateServer) error
}

type ValueService_NoisyUpdateClient

type ValueService_NoisyUpdateClient interface {
	Send(*Update) error
	Recv() (*Summary, error)
	grpc.ClientStream
}

type ValueService_NoisyUpdateServer

type ValueService_NoisyUpdateServer interface {
	Send(*Summary) error
	Recv() (*Update, error)
	grpc.ServerStream
}

type ValueService_QuietUpdateClient

type ValueService_QuietUpdateClient interface {
	Send(*Update) error
	CloseAndRecv() (*Summary, error)
	grpc.ClientStream
}

type ValueService_QuietUpdateServer

type ValueService_QuietUpdateServer interface {
	SendAndClose(*Summary) error
	Recv() (*Update, error)
	grpc.ServerStream
}

type ValueService_SubscribeClient

type ValueService_SubscribeClient interface {
	Recv() (*Summary, error)
	grpc.ClientStream
}

type ValueService_SubscribeServer

type ValueService_SubscribeServer interface {
	Send(*Summary) error
	grpc.ServerStream
}