rpc

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files:

rpc.proto

It has these top-level messages:

SessionFilter
ListSessionsOutput

Index

• func New(port int, handler broker) io.Closer
• func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)
• type BrokerServiceClient
  • func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient
• type BrokerServiceServer
• type ListSessionsOutput
  • func (*ListSessionsOutput) Descriptor() ([]byte, []int)
  • func (m *ListSessionsOutput) GetSessions() []*sessions.Session
  • func (*ListSessionsOutput) ProtoMessage()
  • func (m *ListSessionsOutput) Reset()
  • func (m *ListSessionsOutput) String() string
• type SessionFilter
  • func (*SessionFilter) Descriptor() ([]byte, []int)
  • func (*SessionFilter) ProtoMessage()
  • func (m *SessionFilter) Reset()
  • func (m *SessionFilter) String() string

Functions

func New

func New(port int, handler broker) io.Closer

func RegisterBrokerServiceServer

func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)

Types

type BrokerServiceClient

type BrokerServiceClient interface {
	ListSessions(ctx context.Context, in *SessionFilter, opts ...grpc.CallOption) (*ListSessionsOutput, error)
}

func NewBrokerServiceClient

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer

type BrokerServiceServer interface {
	ListSessions(context.Context, *SessionFilter) (*ListSessionsOutput, error)
}

type ListSessionsOutput

type ListSessionsOutput struct {
	Sessions []*sessions.Session `protobuf:"bytes,1,rep,name=Sessions" json:"Sessions,omitempty"`
}

func (*ListSessionsOutput) Descriptor

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

func (*ListSessionsOutput) GetSessions

func (m *ListSessionsOutput) GetSessions() []*sessions.Session

func (*ListSessionsOutput) ProtoMessage

func (*ListSessionsOutput) ProtoMessage()

func (*ListSessionsOutput) Reset

func (m *ListSessionsOutput) Reset()

func (*ListSessionsOutput) String

func (m *ListSessionsOutput) String() string

type SessionFilter

type SessionFilter struct {
}

func (*SessionFilter) Descriptor

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

func (*SessionFilter) ProtoMessage

func (*SessionFilter) ProtoMessage()

func (*SessionFilter) Reset

func (m *SessionFilter) Reset()

func (*SessionFilter) String

func (m *SessionFilter) String() string