Versions in this module Expand all Collapse all v0 v0.1.1 May 7, 2020 v0.1.0 Apr 29, 2020 Changes in this version + var ErrIntOverflowTicker = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTicker = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTicker = fmt.Errorf("proto: unexpected end of group") + func Run(ctx context.Context, log *zap.Logger, nc *nats.Conn, subject string) error + type Service struct + func New(log *zap.Logger, mq *nats.Conn, subject string) *Service + func (p Service) TimeService(in *TimeRequest, stream TimeServiceServer) error + type TimeRequest struct + Every int32 + Max int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeRequest) Descriptor() ([]byte, []int) + func (*TimeRequest) ProtoMessage() + func (m *TimeRequest) GetEvery() int32 + func (m *TimeRequest) GetMax() int32 + func (m *TimeRequest) Marshal() (dAtA []byte, err error) + func (m *TimeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TimeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeRequest) Reset() + func (m *TimeRequest) Size() (n int) + func (m *TimeRequest) String() string + func (m *TimeRequest) Unmarshal(dAtA []byte) error + func (m *TimeRequest) XXX_DiscardUnknown() + func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeRequest) XXX_Merge(src proto.Message) + func (m *TimeRequest) XXX_Size() int + func (m *TimeRequest) XXX_Unmarshal(b []byte) error + type TimeResponse struct + Ts *types.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeResponse) Descriptor() ([]byte, []int) + func (*TimeResponse) ProtoMessage() + func (m *TimeResponse) GetTs() *types.Timestamp + func (m *TimeResponse) Marshal() (dAtA []byte, err error) + func (m *TimeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TimeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeResponse) Reset() + func (m *TimeResponse) Size() (n int) + func (m *TimeResponse) String() string + func (m *TimeResponse) Unmarshal(dAtA []byte) error + func (m *TimeResponse) XXX_DiscardUnknown() + func (m *TimeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeResponse) XXX_Merge(src proto.Message) + func (m *TimeResponse) XXX_Size() int + func (m *TimeResponse) XXX_Unmarshal(b []byte) error + type TimeServiceServer interface + Context func() context.Context + Send func(data *TimeResponse) error