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
CloseSessionInput
CloseSessionOutput
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 CloseSessionInput
  • func (*CloseSessionInput) Descriptor() ([]byte, []int)
  • func (m *CloseSessionInput) GetID() string
  • func (*CloseSessionInput) ProtoMessage()
  • func (m *CloseSessionInput) Reset()
  • func (m *CloseSessionInput) String() string
• type CloseSessionOutput
  • func (*CloseSessionOutput) Descriptor() ([]byte, []int)
  • func (m *CloseSessionOutput) GetID() string
  • func (*CloseSessionOutput) ProtoMessage()
  • func (m *CloseSessionOutput) Reset()
  • func (m *CloseSessionOutput) String() string
• 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)
	CloseSession(ctx context.Context, in *CloseSessionInput, opts ...grpc.CallOption) (*CloseSessionOutput, error)
}

func NewBrokerServiceClient

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer

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

type CloseSessionInput

type CloseSessionInput struct {
	ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
}

func (*CloseSessionInput) Descriptor

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

func (*CloseSessionInput) GetID

func (m *CloseSessionInput) GetID() string

func (*CloseSessionInput) ProtoMessage

func (*CloseSessionInput) ProtoMessage()

func (*CloseSessionInput) Reset

func (m *CloseSessionInput) Reset()

func (*CloseSessionInput) String

func (m *CloseSessionInput) String() string

type CloseSessionOutput

type CloseSessionOutput struct {
	ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
}

func (*CloseSessionOutput) Descriptor

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

func (*CloseSessionOutput) GetID

func (m *CloseSessionOutput) GetID() string

func (*CloseSessionOutput) ProtoMessage

func (*CloseSessionOutput) ProtoMessage()

func (*CloseSessionOutput) Reset

func (m *CloseSessionOutput) Reset()

func (*CloseSessionOutput) String

func (m *CloseSessionOutput) String() string

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