protobuf

Documentation

Overview

Package protobuf is a generated protocol buffer package.

It is generated from these files:

time.proto

It has these top-level messages:

TimeRequest
Time

Index

• func RegisterTimeServiceServer(s *grpc.Server, srv TimeServiceServer)
• type Time
  • func (*Time) Descriptor() ([]byte, []int)
  • func (m *Time) GetValue() []byte
  • func (*Time) ProtoMessage()
  • func (m *Time) Reset()
  • func (m *Time) String() string
• type TimeRequest
  • func (*TimeRequest) Descriptor() ([]byte, []int)
  • func (m *TimeRequest) GetInterval() int32
  • func (*TimeRequest) ProtoMessage()
  • func (m *TimeRequest) Reset()
  • func (m *TimeRequest) String() string
• type TimeServiceClient
  • func NewTimeServiceClient(cc *grpc.ClientConn) TimeServiceClient
• type TimeServiceServer
• type TimeService_GetTimeStreamClient
• type TimeService_GetTimeStreamServer

Functions

func RegisterTimeServiceServer

func RegisterTimeServiceServer(s *grpc.Server, srv TimeServiceServer)

Types

type Time

type Time struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

Time represents a time value

func (*Time) Descriptor

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

func (*Time) GetValue

func (m *Time) GetValue() []byte

func (*Time) ProtoMessage

func (*Time) ProtoMessage()

func (*Time) Reset

func (m *Time) Reset()

func (*Time) String

func (m *Time) String() string

type TimeRequest

type TimeRequest struct {
	Interval int32 `protobuf:"varint,1,opt,name=interval" json:"interval,omitempty"`
}

TimeRequest requests a time

func (*TimeRequest) Descriptor

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

func (*TimeRequest) GetInterval

func (m *TimeRequest) GetInterval() int32

func (*TimeRequest) ProtoMessage

func (*TimeRequest) ProtoMessage()

func (*TimeRequest) Reset

func (m *TimeRequest) Reset()

func (*TimeRequest) String

func (m *TimeRequest) String() string

type TimeServiceClient

type TimeServiceClient interface {
	// GetTimeStream returns a stream of time messages at specified millis intervals
	GetTimeStream(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (TimeService_GetTimeStreamClient, error)
}

func NewTimeServiceClient

func NewTimeServiceClient(cc *grpc.ClientConn) TimeServiceClient

type TimeServiceServer

type TimeServiceServer interface {
	// GetTimeStream returns a stream of time messages at specified millis intervals
	GetTimeStream(*TimeRequest, TimeService_GetTimeStreamServer) error
}

type TimeService_GetTimeStreamClient

type TimeService_GetTimeStreamClient interface {
	Recv() (*Time, error)
	grpc.ClientStream
}

type TimeService_GetTimeStreamServer

type TimeService_GetTimeStreamServer interface {
	Send(*Time) error
	grpc.ServerStream
}