pb

package
v0.0.0-...-7f180d0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 14, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-stmp. DO NOT EDIT. source: examples/quick_start/quick_start_pb/quick_start.proto

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuickStart        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuickStart          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuickStart = fmt.Errorf("proto: unexpected end of group")
)

Functions

func STMPAttachRoomEventsListener 

func STMPAttachRoomEventsListener(c *stmp.Client, s STMPRoomEventsListener)

func STMPDetachRoomEventsListener 

func STMPDetachRoomEventsListener(c *stmp.Client, s STMPRoomEventsListener)

func STMPRegisterRoomServiceServer 

func STMPRegisterRoomServiceServer(srv *stmp.Server, s STMPRoomServiceServer)

Types

type ExitRoomInput 

type ExitRoomInput struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExitRoomInput) Descriptor 

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

func (*ExitRoomInput) Marshal 

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

func (*ExitRoomInput) MarshalTo 

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

func (*ExitRoomInput) MarshalToSizedBuffer 

func (m *ExitRoomInput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExitRoomInput) ProtoMessage 

func (*ExitRoomInput) ProtoMessage()

func (*ExitRoomInput) Reset 

func (m *ExitRoomInput) Reset()

func (*ExitRoomInput) Size 

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

func (*ExitRoomInput) String 

func (m *ExitRoomInput) String() string

func (*ExitRoomInput) Unmarshal 

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

func (*ExitRoomInput) XXX_DiscardUnknown 

func (m *ExitRoomInput) XXX_DiscardUnknown()

func (*ExitRoomInput) XXX_Marshal 

func (m *ExitRoomInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExitRoomInput) XXX_Merge 

func (m *ExitRoomInput) XXX_Merge(src proto.Message)

func (*ExitRoomInput) XXX_Size 

func (m *ExitRoomInput) XXX_Size() int

func (*ExitRoomInput) XXX_Unmarshal 

func (m *ExitRoomInput) XXX_Unmarshal(b []byte) error

type JoinRoomInput 

type JoinRoomInput struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinRoomInput) Descriptor 

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

func (*JoinRoomInput) Marshal 

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

func (*JoinRoomInput) MarshalTo 

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

func (*JoinRoomInput) MarshalToSizedBuffer 

func (m *JoinRoomInput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JoinRoomInput) ProtoMessage 

func (*JoinRoomInput) ProtoMessage()

func (*JoinRoomInput) Reset 

func (m *JoinRoomInput) Reset()

func (*JoinRoomInput) Size 

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

func (*JoinRoomInput) String 

func (m *JoinRoomInput) String() string

func (*JoinRoomInput) Unmarshal 

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

func (*JoinRoomInput) XXX_DiscardUnknown 

func (m *JoinRoomInput) XXX_DiscardUnknown()

func (*JoinRoomInput) XXX_Marshal 

func (m *JoinRoomInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinRoomInput) XXX_Merge 

func (m *JoinRoomInput) XXX_Merge(src proto.Message)

func (*JoinRoomInput) XXX_Size 

func (m *JoinRoomInput) XXX_Size() int

func (*JoinRoomInput) XXX_Unmarshal 

func (m *JoinRoomInput) XXX_Unmarshal(b []byte) error

type RoomModel 

type RoomModel struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Users                []string `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RoomModel) Descriptor 

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

func (*RoomModel) Marshal 

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

func (*RoomModel) MarshalTo 

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

func (*RoomModel) MarshalToSizedBuffer 

func (m *RoomModel) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RoomModel) ProtoMessage 

func (*RoomModel) ProtoMessage()

func (*RoomModel) Reset 

func (m *RoomModel) Reset()

func (*RoomModel) Size 

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

func (*RoomModel) String 

func (m *RoomModel) String() string

func (*RoomModel) Unmarshal 

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

func (*RoomModel) XXX_DiscardUnknown 

func (m *RoomModel) XXX_DiscardUnknown()

func (*RoomModel) XXX_Marshal 

func (m *RoomModel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoomModel) XXX_Merge 

func (m *RoomModel) XXX_Merge(src proto.Message)

func (*RoomModel) XXX_Size 

func (m *RoomModel) XXX_Size() int

func (*RoomModel) XXX_Unmarshal 

func (m *RoomModel) XXX_Unmarshal(b []byte) error

type STMPRoomEventsBroadcaster 

type STMPRoomEventsBroadcaster struct{}

func (STMPRoomEventsBroadcaster) UserExit 

func (s STMPRoomEventsBroadcaster) UserExit(ctx context.Context, in *UserExitEvent, conn *stmp.Conn, opts ...*stmp.CallOptions) error

func (STMPRoomEventsBroadcaster) UserExitToAll 

func (s STMPRoomEventsBroadcaster) UserExitToAll(ctx context.Context, in *UserExitEvent, srv *stmp.Server, filter ...stmp.ConnFilter)

func (STMPRoomEventsBroadcaster) UserExitToList 

func (s STMPRoomEventsBroadcaster) UserExitToList(ctx context.Context, in *UserExitEvent, conns ...*stmp.Conn)

func (STMPRoomEventsBroadcaster) UserExitToSet 

func (s STMPRoomEventsBroadcaster) UserExitToSet(ctx context.Context, in *UserExitEvent, conns stmp.ConnSet, exclude ...*stmp.Conn)

func (STMPRoomEventsBroadcaster) UserJoin 

func (s STMPRoomEventsBroadcaster) UserJoin(ctx context.Context, in *UserJoinEvent, conn *stmp.Conn, opts ...*stmp.CallOptions) error

func (STMPRoomEventsBroadcaster) UserJoinToAll 

func (s STMPRoomEventsBroadcaster) UserJoinToAll(ctx context.Context, in *UserJoinEvent, srv *stmp.Server, filter ...stmp.ConnFilter)

func (STMPRoomEventsBroadcaster) UserJoinToList 

func (s STMPRoomEventsBroadcaster) UserJoinToList(ctx context.Context, in *UserJoinEvent, conns ...*stmp.Conn)

func (STMPRoomEventsBroadcaster) UserJoinToSet 

func (s STMPRoomEventsBroadcaster) UserJoinToSet(ctx context.Context, in *UserJoinEvent, conns stmp.ConnSet, exclude ...*stmp.Conn)

type STMPRoomEventsListener 

type STMPRoomEventsListener interface {
	HandleUserJoin(ctx context.Context, in *UserJoinEvent)
	HandleUserExit(ctx context.Context, in *UserExitEvent)
}

type STMPRoomServiceClient 

type STMPRoomServiceClient interface {
	JoinRoom(ctx context.Context, in *JoinRoomInput, opts ...*stmp.CallOptions) (*RoomModel, error)
	ExitRoom(ctx context.Context, in *ExitRoomInput, opts ...*stmp.CallOptions) (*empty.Empty, error)
}

func STMPNewRoomServiceClient 

func STMPNewRoomServiceClient(c *stmp.Client) STMPRoomServiceClient

type STMPRoomServiceServer 

type STMPRoomServiceServer interface {
	JoinRoom(ctx context.Context, in *JoinRoomInput) (out *RoomModel, err error)
	ExitRoom(ctx context.Context, in *ExitRoomInput) (out *empty.Empty, err error)
}

type UserExitEvent 

type UserExitEvent struct {
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserExitEvent) Descriptor 

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

func (*UserExitEvent) Marshal 

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

func (*UserExitEvent) MarshalTo 

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

func (*UserExitEvent) MarshalToSizedBuffer 

func (m *UserExitEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserExitEvent) ProtoMessage 

func (*UserExitEvent) ProtoMessage()

func (*UserExitEvent) Reset 

func (m *UserExitEvent) Reset()

func (*UserExitEvent) Size 

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

func (*UserExitEvent) String 

func (m *UserExitEvent) String() string

func (*UserExitEvent) Unmarshal 

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

func (*UserExitEvent) XXX_DiscardUnknown 

func (m *UserExitEvent) XXX_DiscardUnknown()

func (*UserExitEvent) XXX_Marshal 

func (m *UserExitEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserExitEvent) XXX_Merge 

func (m *UserExitEvent) XXX_Merge(src proto.Message)

func (*UserExitEvent) XXX_Size 

func (m *UserExitEvent) XXX_Size() int

func (*UserExitEvent) XXX_Unmarshal 

func (m *UserExitEvent) XXX_Unmarshal(b []byte) error

type UserJoinEvent 

type UserJoinEvent struct {
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserJoinEvent) Descriptor 

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

func (*UserJoinEvent) Marshal 

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

func (*UserJoinEvent) MarshalTo 

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

func (*UserJoinEvent) MarshalToSizedBuffer 

func (m *UserJoinEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserJoinEvent) ProtoMessage 

func (*UserJoinEvent) ProtoMessage()

func (*UserJoinEvent) Reset 

func (m *UserJoinEvent) Reset()

func (*UserJoinEvent) Size 

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

func (*UserJoinEvent) String 

func (m *UserJoinEvent) String() string

func (*UserJoinEvent) Unmarshal 

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

func (*UserJoinEvent) XXX_DiscardUnknown 

func (m *UserJoinEvent) XXX_DiscardUnknown()

func (*UserJoinEvent) XXX_Marshal 

func (m *UserJoinEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserJoinEvent) XXX_Merge 

func (m *UserJoinEvent) XXX_Merge(src proto.Message)

func (*UserJoinEvent) XXX_Size 

func (m *UserJoinEvent) XXX_Size() int

func (*UserJoinEvent) XXX_Unmarshal 

func (m *UserJoinEvent) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.