proto

package
v0.0.0-...-e285db0 Latest Latest
Warning

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

Go to latest
Published: Jul 18, 2019 License: MIT Imports: 6 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

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 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
}

Jump to

Keyboard shortcuts

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