evntsrc_ttlscheduler

Documentation

Overview

Package evntsrc_ttlscheduler is a generated protocol buffer package.

It is generated from these files:

scheduler.proto

It has these top-level messages:

Stream
Node
Binding
NodeBindingRequest
NodeBindingResponse

Index

• Variables
• func RegisterTTLSchedulerServer(s *grpc.Server, srv TTLSchedulerServer)
• type Binding
  • func (*Binding) Descriptor() ([]byte, []int)
  • func (m *Binding) GetNode() *Node
  • func (m *Binding) GetStream() *Stream
  • func (m *Binding) Marshal() (dAtA []byte, err error)
  • func (m *Binding) MarshalTo(dAtA []byte) (int, error)
  • func (*Binding) ProtoMessage()
  • func (m *Binding) Reset()
  • func (m *Binding) Size() (n int)
  • func (m *Binding) String() string
  • func (m *Binding) Unmarshal(dAtA []byte) error
  • func (*Binding) XXX_MessageName() string
• type Node
  • func (*Node) Descriptor() ([]byte, []int)
  • func (m *Node) GetId() string
  • func (m *Node) Marshal() (dAtA []byte, err error)
  • func (m *Node) MarshalTo(dAtA []byte) (int, error)
  • func (*Node) ProtoMessage()
  • func (m *Node) Reset()
  • func (m *Node) Size() (n int)
  • func (m *Node) String() string
  • func (m *Node) Unmarshal(dAtA []byte) error
  • func (*Node) XXX_MessageName() string
• type NodeBindingRequest
  • func (*NodeBindingRequest) Descriptor() ([]byte, []int)
  • func (m *NodeBindingRequest) GetNode() *Node
  • func (m *NodeBindingRequest) Marshal() (dAtA []byte, err error)
  • func (m *NodeBindingRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*NodeBindingRequest) ProtoMessage()
  • func (m *NodeBindingRequest) Reset()
  • func (m *NodeBindingRequest) Size() (n int)
  • func (m *NodeBindingRequest) String() string
  • func (m *NodeBindingRequest) Unmarshal(dAtA []byte) error
  • func (*NodeBindingRequest) XXX_MessageName() string
• type NodeBindingResponse
  • func (*NodeBindingResponse) Descriptor() ([]byte, []int)
  • func (m *NodeBindingResponse) GetBindings() []*Binding
  • func (m *NodeBindingResponse) Marshal() (dAtA []byte, err error)
  • func (m *NodeBindingResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*NodeBindingResponse) ProtoMessage()
  • func (m *NodeBindingResponse) Reset()
  • func (m *NodeBindingResponse) Size() (n int)
  • func (m *NodeBindingResponse) String() string
  • func (m *NodeBindingResponse) Unmarshal(dAtA []byte) error
  • func (*NodeBindingResponse) XXX_MessageName() string
• type Stream
  • func (*Stream) Descriptor() ([]byte, []int)
  • func (m *Stream) GetId() int32
  • func (m *Stream) GetMsgRate() int64
  • func (m *Stream) Marshal() (dAtA []byte, err error)
  • func (m *Stream) MarshalTo(dAtA []byte) (int, error)
  • func (*Stream) ProtoMessage()
  • func (m *Stream) Reset()
  • func (m *Stream) Size() (n int)
  • func (m *Stream) String() string
  • func (m *Stream) Unmarshal(dAtA []byte) error
  • func (*Stream) XXX_MessageName() string
• type TTLSchedulerClient
  • func NewTTLSchedulerClient(cc *grpc.ClientConn) TTLSchedulerClient
• type TTLSchedulerServer

Variables

var (
	ErrInvalidLengthScheduler = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowScheduler   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTTLSchedulerServer

func RegisterTTLSchedulerServer(s *grpc.Server, srv TTLSchedulerServer)

Types

type Binding

type Binding struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream" json:"stream,omitempty"`
	Node   *Node   `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
}

func (*Binding) Descriptor

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

func (*Binding) GetNode

func (m *Binding) GetNode() *Node

func (*Binding) GetStream

func (m *Binding) GetStream() *Stream

func (*Binding) Marshal

func (m *Binding) Marshal() (dAtA []byte, err error)

func (*Binding) MarshalTo

func (m *Binding) MarshalTo(dAtA []byte) (int, error)

func (*Binding) ProtoMessage

func (*Binding) ProtoMessage()

func (*Binding) Reset

func (m *Binding) Reset()

func (*Binding) Size

func (m *Binding) Size() (n int)

func (*Binding) String

func (m *Binding) String() string

func (*Binding) Unmarshal

func (m *Binding) Unmarshal(dAtA []byte) error

func (*Binding) XXX_MessageName

func (*Binding) XXX_MessageName() string

type Node

type Node struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*Node) Descriptor

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

func (*Node) GetId

func (m *Node) GetId() string

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_MessageName

func (*Node) XXX_MessageName() string

type NodeBindingRequest

type NodeBindingRequest struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func (*NodeBindingRequest) Descriptor

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

func (*NodeBindingRequest) GetNode

func (m *NodeBindingRequest) GetNode() *Node

func (*NodeBindingRequest) Marshal

func (m *NodeBindingRequest) Marshal() (dAtA []byte, err error)

func (*NodeBindingRequest) MarshalTo

func (m *NodeBindingRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodeBindingRequest) ProtoMessage

func (*NodeBindingRequest) ProtoMessage()

func (*NodeBindingRequest) Reset

func (m *NodeBindingRequest) Reset()

func (*NodeBindingRequest) Size

func (m *NodeBindingRequest) Size() (n int)

func (*NodeBindingRequest) String

func (m *NodeBindingRequest) String() string

func (*NodeBindingRequest) Unmarshal

func (m *NodeBindingRequest) Unmarshal(dAtA []byte) error

func (*NodeBindingRequest) XXX_MessageName

func (*NodeBindingRequest) XXX_MessageName() string

type NodeBindingResponse

type NodeBindingResponse struct {
	Bindings []*Binding `protobuf:"bytes,1,rep,name=bindings" json:"bindings,omitempty"`
}

func (*NodeBindingResponse) Descriptor

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

func (*NodeBindingResponse) GetBindings

func (m *NodeBindingResponse) GetBindings() []*Binding

func (*NodeBindingResponse) Marshal

func (m *NodeBindingResponse) Marshal() (dAtA []byte, err error)

func (*NodeBindingResponse) MarshalTo

func (m *NodeBindingResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodeBindingResponse) ProtoMessage

func (*NodeBindingResponse) ProtoMessage()

func (*NodeBindingResponse) Reset

func (m *NodeBindingResponse) Reset()

func (*NodeBindingResponse) Size

func (m *NodeBindingResponse) Size() (n int)

func (*NodeBindingResponse) String

func (m *NodeBindingResponse) String() string

func (*NodeBindingResponse) Unmarshal

func (m *NodeBindingResponse) Unmarshal(dAtA []byte) error

func (*NodeBindingResponse) XXX_MessageName

func (*NodeBindingResponse) XXX_MessageName() string

type Stream

type Stream struct {
	Id      int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MsgRate int64 `protobuf:"varint,2,opt,name=msgRate,proto3" json:"msgRate,omitempty"`
}

func (*Stream) Descriptor

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

func (*Stream) GetId

func (m *Stream) GetId() int32

func (*Stream) GetMsgRate

func (m *Stream) GetMsgRate() int64

func (*Stream) Marshal

func (m *Stream) Marshal() (dAtA []byte, err error)

func (*Stream) MarshalTo

func (m *Stream) MarshalTo(dAtA []byte) (int, error)

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) Reset

func (m *Stream) Reset()

func (*Stream) Size

func (m *Stream) Size() (n int)

func (*Stream) String

func (m *Stream) String() string

func (*Stream) Unmarshal

func (m *Stream) Unmarshal(dAtA []byte) error

func (*Stream) XXX_MessageName

func (*Stream) XXX_MessageName() string

type TTLSchedulerClient

type TTLSchedulerClient interface {
	NodeBindings(ctx context.Context, in *NodeBindingRequest, opts ...grpc.CallOption) (*NodeBindingResponse, error)
}

func NewTTLSchedulerClient

func NewTTLSchedulerClient(cc *grpc.ClientConn) TTLSchedulerClient

type TTLSchedulerServer

type TTLSchedulerServer interface {
	NodeBindings(context.Context, *NodeBindingRequest) (*NodeBindingResponse, error)
}