Documentation ¶
Index ¶
- Variables
- func RegisterEmitEventsHelperServer(s grpc.ServiceRegistrar, srv EmitEventsHelperServer)
- func RegisterEventHandlerServer(s grpc.ServiceRegistrar, srv EventHandlerServer)
- type AuthenticateUserRequest
- func (*AuthenticateUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticateUserRequest) GetIdToken() string
- func (x *AuthenticateUserRequest) GetProvider() string
- func (*AuthenticateUserRequest) ProtoMessage()
- func (x *AuthenticateUserRequest) ProtoReflect() protoreflect.Message
- func (x *AuthenticateUserRequest) Reset()
- func (x *AuthenticateUserRequest) String() string
- type AuthenticateUserResponse
- func (*AuthenticateUserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticateUserResponse) GetUser() *User
- func (*AuthenticateUserResponse) ProtoMessage()
- func (x *AuthenticateUserResponse) ProtoReflect() protoreflect.Message
- func (x *AuthenticateUserResponse) Reset()
- func (x *AuthenticateUserResponse) String() string
- type ChangeRoomTagsRequest
- func (*ChangeRoomTagsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeRoomTagsRequest) GetRoomId() string
- func (x *ChangeRoomTagsRequest) GetTagUpdate() []*TagUpdate
- func (*ChangeRoomTagsRequest) ProtoMessage()
- func (x *ChangeRoomTagsRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeRoomTagsRequest) Reset()
- func (x *ChangeRoomTagsRequest) String() string
- type ChangeRoomTagsResponse
- func (*ChangeRoomTagsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeRoomTagsResponse) GetOk() []bool
- func (x *ChangeRoomTagsResponse) GetRoom() *Room
- func (*ChangeRoomTagsResponse) ProtoMessage()
- func (x *ChangeRoomTagsResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeRoomTagsResponse) Reset()
- func (x *ChangeRoomTagsResponse) String() string
- type ChangeUserTagsRequest
- func (*ChangeUserTagsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeUserTagsRequest) GetTagUpdate() []*TagUpdate
- func (x *ChangeUserTagsRequest) GetUserId() string
- func (*ChangeUserTagsRequest) ProtoMessage()
- func (x *ChangeUserTagsRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeUserTagsRequest) Reset()
- func (x *ChangeUserTagsRequest) String() string
- type ChangeUserTagsResponse
- func (*ChangeUserTagsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeUserTagsResponse) GetOk() []bool
- func (x *ChangeUserTagsResponse) GetUser() *User
- func (*ChangeUserTagsResponse) ProtoMessage()
- func (x *ChangeUserTagsResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeUserTagsResponse) Reset()
- func (x *ChangeUserTagsResponse) String() string
- type ConfigureRequest
- type ConfigureResponse
- func (*ConfigureResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigureResponse) GetCronSpec() string
- func (x *ConfigureResponse) GetEventsFilter() string
- func (*ConfigureResponse) ProtoMessage()
- func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigureResponse) Reset()
- func (x *ConfigureResponse) String() string
- type CronRequest
- type CronResponse
- type EmitEventsHelperClient
- type EmitEventsHelperServer
- type EmitEventsRequest
- type EmitEventsResponse
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetCreated() int64
- func (x *Event) GetHistory() bool
- func (x *Event) GetId() string
- func (x *Event) GetLanguage() string
- func (x *Event) GetName() string
- func (x *Event) GetRoom() *Room
- func (x *Event) GetSent() int64
- func (x *Event) GetSource() *Source
- func (x *Event) GetTags() map[string]string
- func (x *Event) GetTargetFilter() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventHandlerClient
- type EventHandlerServer
- type GetRoomRequest
- type GetRoomResponse
- type GetUserRequest
- type GetUserResponse
- type HandleEventsRequest
- func (*HandleEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HandleEventsRequest) GetEvents() []*Event
- func (*HandleEventsRequest) ProtoMessage()
- func (x *HandleEventsRequest) ProtoReflect() protoreflect.Message
- func (x *HandleEventsRequest) Reset()
- func (x *HandleEventsRequest) String() string
- type HandleEventsResponse
- func (*HandleEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HandleEventsResponse) GetEvents() []*Event
- func (*HandleEventsResponse) ProtoMessage()
- func (x *HandleEventsResponse) ProtoReflect() protoreflect.Message
- func (x *HandleEventsResponse) Reset()
- func (x *HandleEventsResponse) String() string
- type InitEmitEventsRequest
- func (*InitEmitEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitEmitEventsRequest) GetEmitEventsServer() uint32
- func (x *InitEmitEventsRequest) GetRoom() *Room
- func (*InitEmitEventsRequest) ProtoMessage()
- func (x *InitEmitEventsRequest) ProtoReflect() protoreflect.Message
- func (x *InitEmitEventsRequest) Reset()
- func (x *InitEmitEventsRequest) String() string
- type InitEmitEventsResponse
- type Room
- type Source
- type TagUpdate
- func (*TagUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *TagUpdate) GetExpression() string
- func (x *TagUpdate) GetIndex() int64
- func (x *TagUpdate) GetName() string
- func (x *TagUpdate) GetType() TagUpdate_TagValueType
- func (*TagUpdate) ProtoMessage()
- func (x *TagUpdate) ProtoReflect() protoreflect.Message
- func (x *TagUpdate) Reset()
- func (x *TagUpdate) String() string
- type TagUpdate_TagValueType
- func (TagUpdate_TagValueType) Descriptor() protoreflect.EnumDescriptor
- func (x TagUpdate_TagValueType) Enum() *TagUpdate_TagValueType
- func (TagUpdate_TagValueType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TagUpdate_TagValueType) Number() protoreflect.EnumNumber
- func (x TagUpdate_TagValueType) String() string
- func (TagUpdate_TagValueType) Type() protoreflect.EnumType
- type UnimplementedEmitEventsHelperServer
- func (UnimplementedEmitEventsHelperServer) AuthenticateUser(context.Context, *AuthenticateUserRequest) (*AuthenticateUserResponse, error)
- func (UnimplementedEmitEventsHelperServer) ChangeRoomTags(context.Context, *ChangeRoomTagsRequest) (*ChangeRoomTagsResponse, error)
- func (UnimplementedEmitEventsHelperServer) ChangeUserTags(context.Context, *ChangeUserTagsRequest) (*ChangeUserTagsResponse, error)
- func (UnimplementedEmitEventsHelperServer) EmitEvents(context.Context, *EmitEventsRequest) (*EmitEventsResponse, error)
- func (UnimplementedEmitEventsHelperServer) GetRoom(context.Context, *GetRoomRequest) (*GetRoomResponse, error)
- func (UnimplementedEmitEventsHelperServer) GetUser(context.Context, *GetUserRequest) (*GetUserResponse, error)
- type UnimplementedEventHandlerServer
- func (UnimplementedEventHandlerServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
- func (UnimplementedEventHandlerServer) Cron(context.Context, *CronRequest) (*CronResponse, error)
- func (UnimplementedEventHandlerServer) HandleEvents(context.Context, *HandleEventsRequest) (*HandleEventsResponse, error)
- func (UnimplementedEventHandlerServer) InitEmitEvents(context.Context, *InitEmitEventsRequest) (*InitEmitEventsResponse, error)
- type UnsafeEmitEventsHelperServer
- type UnsafeEventHandlerServer
- type User
- func (*User) Descriptor() ([]byte, []int)deprecated
- func (x *User) GetId() string
- func (x *User) GetLanguage() string
- func (x *User) GetLastOnline() int64
- func (x *User) GetNick() string
- func (x *User) GetTags() map[string]string
- func (*User) ProtoMessage()
- func (x *User) ProtoReflect() protoreflect.Message
- func (x *User) Reset()
- func (x *User) String() string
Constants ¶
This section is empty.
Variables ¶
var ( TagUpdate_TagValueType_name = map[int32]string{ 0: "STRING", 1: "INT", 2: "FLOAT", 3: "STRINGSLICE", 4: "INTSLICE", 5: "FLOATSLICE", } TagUpdate_TagValueType_value = map[string]int32{ "STRING": 0, "INT": 1, "FLOAT": 2, "STRINGSLICE": 3, "INTSLICE": 4, "FLOATSLICE": 5, } )
Enum value maps for TagUpdate_TagValueType.
var EmitEventsHelper_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.EmitEventsHelper", HandlerType: (*EmitEventsHelperServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EmitEvents", Handler: _EmitEventsHelper_EmitEvents_Handler, }, { MethodName: "AuthenticateUser", Handler: _EmitEventsHelper_AuthenticateUser_Handler, }, { MethodName: "GetUser", Handler: _EmitEventsHelper_GetUser_Handler, }, { MethodName: "ChangeUserTags", Handler: _EmitEventsHelper_ChangeUserTags_Handler, }, { MethodName: "GetRoom", Handler: _EmitEventsHelper_GetRoom_Handler, }, { MethodName: "ChangeRoomTags", Handler: _EmitEventsHelper_ChangeRoomTags_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/message.proto", }
EmitEventsHelper_ServiceDesc is the grpc.ServiceDesc for EmitEventsHelper service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var EventHandler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.EventHandler", HandlerType: (*EventHandlerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Configure", Handler: _EventHandler_Configure_Handler, }, { MethodName: "Cron", Handler: _EventHandler_Cron_Handler, }, { MethodName: "HandleEvents", Handler: _EventHandler_HandleEvents_Handler, }, { MethodName: "InitEmitEvents", Handler: _EventHandler_InitEmitEvents_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/message.proto", }
EventHandler_ServiceDesc is the grpc.ServiceDesc for EventHandler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_message_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEmitEventsHelperServer ¶
func RegisterEmitEventsHelperServer(s grpc.ServiceRegistrar, srv EmitEventsHelperServer)
func RegisterEventHandlerServer ¶
func RegisterEventHandlerServer(s grpc.ServiceRegistrar, srv EventHandlerServer)
Types ¶
type AuthenticateUserRequest ¶
type AuthenticateUserRequest struct { IdToken string `protobuf:"bytes,1,opt,name=id_token,json=idToken,proto3" json:"id_token,omitempty"` Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"` // contains filtered or unexported fields }
func (*AuthenticateUserRequest) Descriptor
deprecated
func (*AuthenticateUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticateUserRequest.ProtoReflect.Descriptor instead.
func (*AuthenticateUserRequest) GetIdToken ¶
func (x *AuthenticateUserRequest) GetIdToken() string
func (*AuthenticateUserRequest) GetProvider ¶
func (x *AuthenticateUserRequest) GetProvider() string
func (*AuthenticateUserRequest) ProtoMessage ¶
func (*AuthenticateUserRequest) ProtoMessage()
func (*AuthenticateUserRequest) ProtoReflect ¶
func (x *AuthenticateUserRequest) ProtoReflect() protoreflect.Message
func (*AuthenticateUserRequest) Reset ¶
func (x *AuthenticateUserRequest) Reset()
func (*AuthenticateUserRequest) String ¶
func (x *AuthenticateUserRequest) String() string
type AuthenticateUserResponse ¶
type AuthenticateUserResponse struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*AuthenticateUserResponse) Descriptor
deprecated
func (*AuthenticateUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticateUserResponse.ProtoReflect.Descriptor instead.
func (*AuthenticateUserResponse) GetUser ¶
func (x *AuthenticateUserResponse) GetUser() *User
func (*AuthenticateUserResponse) ProtoMessage ¶
func (*AuthenticateUserResponse) ProtoMessage()
func (*AuthenticateUserResponse) ProtoReflect ¶
func (x *AuthenticateUserResponse) ProtoReflect() protoreflect.Message
func (*AuthenticateUserResponse) Reset ¶
func (x *AuthenticateUserResponse) Reset()
func (*AuthenticateUserResponse) String ¶
func (x *AuthenticateUserResponse) String() string
type ChangeRoomTagsRequest ¶
type ChangeRoomTagsRequest struct { RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` TagUpdate []*TagUpdate `protobuf:"bytes,2,rep,name=tag_update,json=tagUpdate,proto3" json:"tag_update,omitempty"` // contains filtered or unexported fields }
func (*ChangeRoomTagsRequest) Descriptor
deprecated
func (*ChangeRoomTagsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeRoomTagsRequest.ProtoReflect.Descriptor instead.
func (*ChangeRoomTagsRequest) GetRoomId ¶
func (x *ChangeRoomTagsRequest) GetRoomId() string
func (*ChangeRoomTagsRequest) GetTagUpdate ¶
func (x *ChangeRoomTagsRequest) GetTagUpdate() []*TagUpdate
func (*ChangeRoomTagsRequest) ProtoMessage ¶
func (*ChangeRoomTagsRequest) ProtoMessage()
func (*ChangeRoomTagsRequest) ProtoReflect ¶
func (x *ChangeRoomTagsRequest) ProtoReflect() protoreflect.Message
func (*ChangeRoomTagsRequest) Reset ¶
func (x *ChangeRoomTagsRequest) Reset()
func (*ChangeRoomTagsRequest) String ¶
func (x *ChangeRoomTagsRequest) String() string
type ChangeRoomTagsResponse ¶
type ChangeRoomTagsResponse struct { Room *Room `protobuf:"bytes,1,opt,name=room,proto3" json:"room,omitempty"` Ok []bool `protobuf:"varint,2,rep,packed,name=ok,proto3" json:"ok,omitempty"` // contains filtered or unexported fields }
func (*ChangeRoomTagsResponse) Descriptor
deprecated
func (*ChangeRoomTagsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeRoomTagsResponse.ProtoReflect.Descriptor instead.
func (*ChangeRoomTagsResponse) GetOk ¶
func (x *ChangeRoomTagsResponse) GetOk() []bool
func (*ChangeRoomTagsResponse) GetRoom ¶
func (x *ChangeRoomTagsResponse) GetRoom() *Room
func (*ChangeRoomTagsResponse) ProtoMessage ¶
func (*ChangeRoomTagsResponse) ProtoMessage()
func (*ChangeRoomTagsResponse) ProtoReflect ¶
func (x *ChangeRoomTagsResponse) ProtoReflect() protoreflect.Message
func (*ChangeRoomTagsResponse) Reset ¶
func (x *ChangeRoomTagsResponse) Reset()
func (*ChangeRoomTagsResponse) String ¶
func (x *ChangeRoomTagsResponse) String() string
type ChangeUserTagsRequest ¶
type ChangeUserTagsRequest struct { UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` TagUpdate []*TagUpdate `protobuf:"bytes,2,rep,name=tag_update,json=tagUpdate,proto3" json:"tag_update,omitempty"` // contains filtered or unexported fields }
func (*ChangeUserTagsRequest) Descriptor
deprecated
func (*ChangeUserTagsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeUserTagsRequest.ProtoReflect.Descriptor instead.
func (*ChangeUserTagsRequest) GetTagUpdate ¶
func (x *ChangeUserTagsRequest) GetTagUpdate() []*TagUpdate
func (*ChangeUserTagsRequest) GetUserId ¶
func (x *ChangeUserTagsRequest) GetUserId() string
func (*ChangeUserTagsRequest) ProtoMessage ¶
func (*ChangeUserTagsRequest) ProtoMessage()
func (*ChangeUserTagsRequest) ProtoReflect ¶
func (x *ChangeUserTagsRequest) ProtoReflect() protoreflect.Message
func (*ChangeUserTagsRequest) Reset ¶
func (x *ChangeUserTagsRequest) Reset()
func (*ChangeUserTagsRequest) String ¶
func (x *ChangeUserTagsRequest) String() string
type ChangeUserTagsResponse ¶
type ChangeUserTagsResponse struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Ok []bool `protobuf:"varint,2,rep,packed,name=ok,proto3" json:"ok,omitempty"` // contains filtered or unexported fields }
func (*ChangeUserTagsResponse) Descriptor
deprecated
func (*ChangeUserTagsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeUserTagsResponse.ProtoReflect.Descriptor instead.
func (*ChangeUserTagsResponse) GetOk ¶
func (x *ChangeUserTagsResponse) GetOk() []bool
func (*ChangeUserTagsResponse) GetUser ¶
func (x *ChangeUserTagsResponse) GetUser() *User
func (*ChangeUserTagsResponse) ProtoMessage ¶
func (*ChangeUserTagsResponse) ProtoMessage()
func (*ChangeUserTagsResponse) ProtoReflect ¶
func (x *ChangeUserTagsResponse) ProtoReflect() protoreflect.Message
func (*ChangeUserTagsResponse) Reset ¶
func (x *ChangeUserTagsResponse) Reset()
func (*ChangeUserTagsResponse) String ¶
func (x *ChangeUserTagsResponse) String() string
type ConfigureRequest ¶
type ConfigureRequest struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ConfigureRequest) Descriptor
deprecated
func (*ConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.
func (*ConfigureRequest) GetData ¶
func (x *ConfigureRequest) GetData() []byte
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) ProtoReflect ¶
func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
func (*ConfigureRequest) Reset ¶
func (x *ConfigureRequest) Reset()
func (*ConfigureRequest) String ¶
func (x *ConfigureRequest) String() string
type ConfigureResponse ¶
type ConfigureResponse struct { CronSpec string `protobuf:"bytes,1,opt,name=cron_spec,json=cronSpec,proto3" json:"cron_spec,omitempty"` EventsFilter string `protobuf:"bytes,2,opt,name=events_filter,json=eventsFilter,proto3" json:"events_filter,omitempty"` // contains filtered or unexported fields }
func (*ConfigureResponse) Descriptor
deprecated
func (*ConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.
func (*ConfigureResponse) GetCronSpec ¶
func (x *ConfigureResponse) GetCronSpec() string
func (*ConfigureResponse) GetEventsFilter ¶
func (x *ConfigureResponse) GetEventsFilter() string
func (*ConfigureResponse) ProtoMessage ¶
func (*ConfigureResponse) ProtoMessage()
func (*ConfigureResponse) ProtoReflect ¶
func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
func (*ConfigureResponse) Reset ¶
func (x *ConfigureResponse) Reset()
func (*ConfigureResponse) String ¶
func (x *ConfigureResponse) String() string
type CronRequest ¶
type CronRequest struct { Room *Room `protobuf:"bytes,1,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*CronRequest) Descriptor
deprecated
func (*CronRequest) Descriptor() ([]byte, []int)
Deprecated: Use CronRequest.ProtoReflect.Descriptor instead.
func (*CronRequest) GetRoom ¶
func (x *CronRequest) GetRoom() *Room
func (*CronRequest) ProtoMessage ¶
func (*CronRequest) ProtoMessage()
func (*CronRequest) ProtoReflect ¶
func (x *CronRequest) ProtoReflect() protoreflect.Message
func (*CronRequest) Reset ¶
func (x *CronRequest) Reset()
func (*CronRequest) String ¶
func (x *CronRequest) String() string
type CronResponse ¶
type CronResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*CronResponse) Descriptor
deprecated
func (*CronResponse) Descriptor() ([]byte, []int)
Deprecated: Use CronResponse.ProtoReflect.Descriptor instead.
func (*CronResponse) GetEvents ¶
func (x *CronResponse) GetEvents() []*Event
func (*CronResponse) ProtoMessage ¶
func (*CronResponse) ProtoMessage()
func (*CronResponse) ProtoReflect ¶
func (x *CronResponse) ProtoReflect() protoreflect.Message
func (*CronResponse) Reset ¶
func (x *CronResponse) Reset()
func (*CronResponse) String ¶
func (x *CronResponse) String() string
type EmitEventsHelperClient ¶
type EmitEventsHelperClient interface { EmitEvents(ctx context.Context, in *EmitEventsRequest, opts ...grpc.CallOption) (*EmitEventsResponse, error) AuthenticateUser(ctx context.Context, in *AuthenticateUserRequest, opts ...grpc.CallOption) (*AuthenticateUserResponse, error) GetUser(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error) ChangeUserTags(ctx context.Context, in *ChangeUserTagsRequest, opts ...grpc.CallOption) (*ChangeUserTagsResponse, error) GetRoom(ctx context.Context, in *GetRoomRequest, opts ...grpc.CallOption) (*GetRoomResponse, error) ChangeRoomTags(ctx context.Context, in *ChangeRoomTagsRequest, opts ...grpc.CallOption) (*ChangeRoomTagsResponse, error) }
EmitEventsHelperClient is the client API for EmitEventsHelper service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEmitEventsHelperClient ¶
func NewEmitEventsHelperClient(cc grpc.ClientConnInterface) EmitEventsHelperClient
type EmitEventsHelperServer ¶
type EmitEventsHelperServer interface { EmitEvents(context.Context, *EmitEventsRequest) (*EmitEventsResponse, error) AuthenticateUser(context.Context, *AuthenticateUserRequest) (*AuthenticateUserResponse, error) GetUser(context.Context, *GetUserRequest) (*GetUserResponse, error) ChangeUserTags(context.Context, *ChangeUserTagsRequest) (*ChangeUserTagsResponse, error) GetRoom(context.Context, *GetRoomRequest) (*GetRoomResponse, error) ChangeRoomTags(context.Context, *ChangeRoomTagsRequest) (*ChangeRoomTagsResponse, error) // contains filtered or unexported methods }
EmitEventsHelperServer is the server API for EmitEventsHelper service. All implementations must embed UnimplementedEmitEventsHelperServer for forward compatibility
type EmitEventsRequest ¶
type EmitEventsRequest struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*EmitEventsRequest) Descriptor
deprecated
func (*EmitEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmitEventsRequest.ProtoReflect.Descriptor instead.
func (*EmitEventsRequest) GetEvents ¶
func (x *EmitEventsRequest) GetEvents() []*Event
func (*EmitEventsRequest) ProtoMessage ¶
func (*EmitEventsRequest) ProtoMessage()
func (*EmitEventsRequest) ProtoReflect ¶
func (x *EmitEventsRequest) ProtoReflect() protoreflect.Message
func (*EmitEventsRequest) Reset ¶
func (x *EmitEventsRequest) Reset()
func (*EmitEventsRequest) String ¶
func (x *EmitEventsRequest) String() string
type EmitEventsResponse ¶
type EmitEventsResponse struct {
// contains filtered or unexported fields
}
func (*EmitEventsResponse) Descriptor
deprecated
func (*EmitEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmitEventsResponse.ProtoReflect.Descriptor instead.
func (*EmitEventsResponse) ProtoMessage ¶
func (*EmitEventsResponse) ProtoMessage()
func (*EmitEventsResponse) ProtoReflect ¶
func (x *EmitEventsResponse) ProtoReflect() protoreflect.Message
func (*EmitEventsResponse) Reset ¶
func (x *EmitEventsResponse) Reset()
func (*EmitEventsResponse) String ¶
func (x *EmitEventsResponse) String() string
type Event ¶
type Event struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Room *Room `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"` Source *Source `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Created int64 `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"` Language string `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"` Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ Sent int64 `protobuf:"varint,8,opt,name=sent,proto3" json:"sent,omitempty"` TargetFilter string `protobuf:"bytes,9,opt,name=target_filter,json=targetFilter,proto3" json:"target_filter,omitempty"` History bool `protobuf:"varint,10,opt,name=history,proto3" json:"history,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetCreated ¶
func (*Event) GetHistory ¶
func (*Event) GetLanguage ¶
func (*Event) GetTargetFilter ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventHandlerClient ¶
type EventHandlerClient interface { Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error) Cron(ctx context.Context, in *CronRequest, opts ...grpc.CallOption) (*CronResponse, error) HandleEvents(ctx context.Context, in *HandleEventsRequest, opts ...grpc.CallOption) (*HandleEventsResponse, error) InitEmitEvents(ctx context.Context, in *InitEmitEventsRequest, opts ...grpc.CallOption) (*InitEmitEventsResponse, error) }
EventHandlerClient is the client API for EventHandler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEventHandlerClient ¶
func NewEventHandlerClient(cc grpc.ClientConnInterface) EventHandlerClient
type EventHandlerServer ¶
type EventHandlerServer interface { Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) Cron(context.Context, *CronRequest) (*CronResponse, error) HandleEvents(context.Context, *HandleEventsRequest) (*HandleEventsResponse, error) InitEmitEvents(context.Context, *InitEmitEventsRequest) (*InitEmitEventsResponse, error) // contains filtered or unexported methods }
EventHandlerServer is the server API for EventHandler service. All implementations must embed UnimplementedEventHandlerServer for forward compatibility
type GetRoomRequest ¶
type GetRoomRequest struct { RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` // contains filtered or unexported fields }
func (*GetRoomRequest) Descriptor
deprecated
func (*GetRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRoomRequest.ProtoReflect.Descriptor instead.
func (*GetRoomRequest) GetRoomId ¶
func (x *GetRoomRequest) GetRoomId() string
func (*GetRoomRequest) ProtoMessage ¶
func (*GetRoomRequest) ProtoMessage()
func (*GetRoomRequest) ProtoReflect ¶
func (x *GetRoomRequest) ProtoReflect() protoreflect.Message
func (*GetRoomRequest) Reset ¶
func (x *GetRoomRequest) Reset()
func (*GetRoomRequest) String ¶
func (x *GetRoomRequest) String() string
type GetRoomResponse ¶
type GetRoomResponse struct { Room *Room `protobuf:"bytes,1,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*GetRoomResponse) Descriptor
deprecated
func (*GetRoomResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRoomResponse.ProtoReflect.Descriptor instead.
func (*GetRoomResponse) GetRoom ¶
func (x *GetRoomResponse) GetRoom() *Room
func (*GetRoomResponse) ProtoMessage ¶
func (*GetRoomResponse) ProtoMessage()
func (*GetRoomResponse) ProtoReflect ¶
func (x *GetRoomResponse) ProtoReflect() protoreflect.Message
func (*GetRoomResponse) Reset ¶
func (x *GetRoomResponse) Reset()
func (*GetRoomResponse) String ¶
func (x *GetRoomResponse) String() string
type GetUserRequest ¶
type GetUserRequest struct { UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*GetUserRequest) Descriptor
deprecated
func (*GetUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.
func (*GetUserRequest) GetUserId ¶
func (x *GetUserRequest) GetUserId() string
func (*GetUserRequest) ProtoMessage ¶
func (*GetUserRequest) ProtoMessage()
func (*GetUserRequest) ProtoReflect ¶
func (x *GetUserRequest) ProtoReflect() protoreflect.Message
func (*GetUserRequest) Reset ¶
func (x *GetUserRequest) Reset()
func (*GetUserRequest) String ¶
func (x *GetUserRequest) String() string
type GetUserResponse ¶
type GetUserResponse struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*GetUserResponse) Descriptor
deprecated
func (*GetUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUserResponse.ProtoReflect.Descriptor instead.
func (*GetUserResponse) GetUser ¶
func (x *GetUserResponse) GetUser() *User
func (*GetUserResponse) ProtoMessage ¶
func (*GetUserResponse) ProtoMessage()
func (*GetUserResponse) ProtoReflect ¶
func (x *GetUserResponse) ProtoReflect() protoreflect.Message
func (*GetUserResponse) Reset ¶
func (x *GetUserResponse) Reset()
func (*GetUserResponse) String ¶
func (x *GetUserResponse) String() string
type HandleEventsRequest ¶
type HandleEventsRequest struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*HandleEventsRequest) Descriptor
deprecated
func (*HandleEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use HandleEventsRequest.ProtoReflect.Descriptor instead.
func (*HandleEventsRequest) GetEvents ¶
func (x *HandleEventsRequest) GetEvents() []*Event
func (*HandleEventsRequest) ProtoMessage ¶
func (*HandleEventsRequest) ProtoMessage()
func (*HandleEventsRequest) ProtoReflect ¶
func (x *HandleEventsRequest) ProtoReflect() protoreflect.Message
func (*HandleEventsRequest) Reset ¶
func (x *HandleEventsRequest) Reset()
func (*HandleEventsRequest) String ¶
func (x *HandleEventsRequest) String() string
type HandleEventsResponse ¶
type HandleEventsResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*HandleEventsResponse) Descriptor
deprecated
func (*HandleEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use HandleEventsResponse.ProtoReflect.Descriptor instead.
func (*HandleEventsResponse) GetEvents ¶
func (x *HandleEventsResponse) GetEvents() []*Event
func (*HandleEventsResponse) ProtoMessage ¶
func (*HandleEventsResponse) ProtoMessage()
func (*HandleEventsResponse) ProtoReflect ¶
func (x *HandleEventsResponse) ProtoReflect() protoreflect.Message
func (*HandleEventsResponse) Reset ¶
func (x *HandleEventsResponse) Reset()
func (*HandleEventsResponse) String ¶
func (x *HandleEventsResponse) String() string
type InitEmitEventsRequest ¶
type InitEmitEventsRequest struct { EmitEventsServer uint32 `protobuf:"varint,1,opt,name=emit_events_server,json=emitEventsServer,proto3" json:"emit_events_server,omitempty"` Room *Room `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*InitEmitEventsRequest) Descriptor
deprecated
func (*InitEmitEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitEmitEventsRequest.ProtoReflect.Descriptor instead.
func (*InitEmitEventsRequest) GetEmitEventsServer ¶
func (x *InitEmitEventsRequest) GetEmitEventsServer() uint32
func (*InitEmitEventsRequest) GetRoom ¶
func (x *InitEmitEventsRequest) GetRoom() *Room
func (*InitEmitEventsRequest) ProtoMessage ¶
func (*InitEmitEventsRequest) ProtoMessage()
func (*InitEmitEventsRequest) ProtoReflect ¶
func (x *InitEmitEventsRequest) ProtoReflect() protoreflect.Message
func (*InitEmitEventsRequest) Reset ¶
func (x *InitEmitEventsRequest) Reset()
func (*InitEmitEventsRequest) String ¶
func (x *InitEmitEventsRequest) String() string
type InitEmitEventsResponse ¶
type InitEmitEventsResponse struct {
// contains filtered or unexported fields
}
func (*InitEmitEventsResponse) Descriptor
deprecated
func (*InitEmitEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitEmitEventsResponse.ProtoReflect.Descriptor instead.
func (*InitEmitEventsResponse) ProtoMessage ¶
func (*InitEmitEventsResponse) ProtoMessage()
func (*InitEmitEventsResponse) ProtoReflect ¶
func (x *InitEmitEventsResponse) ProtoReflect() protoreflect.Message
func (*InitEmitEventsResponse) Reset ¶
func (x *InitEmitEventsResponse) Reset()
func (*InitEmitEventsResponse) String ¶
func (x *InitEmitEventsResponse) String() string
type Room ¶
type Room struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Owner *User `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Room) Descriptor
deprecated
func (*Room) ProtoMessage ¶
func (*Room) ProtoMessage()
func (*Room) ProtoReflect ¶
func (x *Room) ProtoReflect() protoreflect.Message
type Source ¶
type Source struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` PluginName string `protobuf:"bytes,2,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"` // contains filtered or unexported fields }
func (*Source) Descriptor
deprecated
func (*Source) GetPluginName ¶
func (*Source) ProtoMessage ¶
func (*Source) ProtoMessage()
func (*Source) ProtoReflect ¶
func (x *Source) ProtoReflect() protoreflect.Message
type TagUpdate ¶
type TagUpdate struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type TagUpdate_TagValueType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.TagUpdate_TagValueType" json:"type,omitempty"` Index int64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` Expression string `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"` // contains filtered or unexported fields }
func (*TagUpdate) Descriptor
deprecated
func (*TagUpdate) GetExpression ¶
func (*TagUpdate) GetType ¶
func (x *TagUpdate) GetType() TagUpdate_TagValueType
func (*TagUpdate) ProtoMessage ¶
func (*TagUpdate) ProtoMessage()
func (*TagUpdate) ProtoReflect ¶
func (x *TagUpdate) ProtoReflect() protoreflect.Message
type TagUpdate_TagValueType ¶
type TagUpdate_TagValueType int32
const ( TagUpdate_STRING TagUpdate_TagValueType = 0 TagUpdate_INT TagUpdate_TagValueType = 1 TagUpdate_FLOAT TagUpdate_TagValueType = 2 TagUpdate_STRINGSLICE TagUpdate_TagValueType = 3 TagUpdate_INTSLICE TagUpdate_TagValueType = 4 TagUpdate_FLOATSLICE TagUpdate_TagValueType = 5 )
func (TagUpdate_TagValueType) Descriptor ¶
func (TagUpdate_TagValueType) Descriptor() protoreflect.EnumDescriptor
func (TagUpdate_TagValueType) Enum ¶
func (x TagUpdate_TagValueType) Enum() *TagUpdate_TagValueType
func (TagUpdate_TagValueType) EnumDescriptor
deprecated
func (TagUpdate_TagValueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TagUpdate_TagValueType.Descriptor instead.
func (TagUpdate_TagValueType) Number ¶
func (x TagUpdate_TagValueType) Number() protoreflect.EnumNumber
func (TagUpdate_TagValueType) String ¶
func (x TagUpdate_TagValueType) String() string
func (TagUpdate_TagValueType) Type ¶
func (TagUpdate_TagValueType) Type() protoreflect.EnumType
type UnimplementedEmitEventsHelperServer ¶
type UnimplementedEmitEventsHelperServer struct { }
UnimplementedEmitEventsHelperServer must be embedded to have forward compatible implementations.
func (UnimplementedEmitEventsHelperServer) AuthenticateUser ¶
func (UnimplementedEmitEventsHelperServer) AuthenticateUser(context.Context, *AuthenticateUserRequest) (*AuthenticateUserResponse, error)
func (UnimplementedEmitEventsHelperServer) ChangeRoomTags ¶
func (UnimplementedEmitEventsHelperServer) ChangeRoomTags(context.Context, *ChangeRoomTagsRequest) (*ChangeRoomTagsResponse, error)
func (UnimplementedEmitEventsHelperServer) ChangeUserTags ¶
func (UnimplementedEmitEventsHelperServer) ChangeUserTags(context.Context, *ChangeUserTagsRequest) (*ChangeUserTagsResponse, error)
func (UnimplementedEmitEventsHelperServer) EmitEvents ¶
func (UnimplementedEmitEventsHelperServer) EmitEvents(context.Context, *EmitEventsRequest) (*EmitEventsResponse, error)
func (UnimplementedEmitEventsHelperServer) GetRoom ¶
func (UnimplementedEmitEventsHelperServer) GetRoom(context.Context, *GetRoomRequest) (*GetRoomResponse, error)
func (UnimplementedEmitEventsHelperServer) GetUser ¶
func (UnimplementedEmitEventsHelperServer) GetUser(context.Context, *GetUserRequest) (*GetUserResponse, error)
type UnimplementedEventHandlerServer ¶
type UnimplementedEventHandlerServer struct { }
UnimplementedEventHandlerServer must be embedded to have forward compatible implementations.
func (UnimplementedEventHandlerServer) Configure ¶
func (UnimplementedEventHandlerServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
func (UnimplementedEventHandlerServer) Cron ¶
func (UnimplementedEventHandlerServer) Cron(context.Context, *CronRequest) (*CronResponse, error)
func (UnimplementedEventHandlerServer) HandleEvents ¶
func (UnimplementedEventHandlerServer) HandleEvents(context.Context, *HandleEventsRequest) (*HandleEventsResponse, error)
func (UnimplementedEventHandlerServer) InitEmitEvents ¶
func (UnimplementedEventHandlerServer) InitEmitEvents(context.Context, *InitEmitEventsRequest) (*InitEmitEventsResponse, error)
type UnsafeEmitEventsHelperServer ¶
type UnsafeEmitEventsHelperServer interface {
// contains filtered or unexported methods
}
UnsafeEmitEventsHelperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EmitEventsHelperServer will result in compilation errors.
type UnsafeEventHandlerServer ¶
type UnsafeEventHandlerServer interface {
// contains filtered or unexported methods
}
UnsafeEventHandlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventHandlerServer will result in compilation errors.
type User ¶
type User struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Nick string `protobuf:"bytes,2,opt,name=nick,proto3" json:"nick,omitempty"` Language string `protobuf:"bytes,3,opt,name=language,proto3" json:"language,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ LastOnline int64 `protobuf:"varint,5,opt,name=last_online,json=lastOnline,proto3" json:"last_online,omitempty"` // contains filtered or unexported fields }
func (*User) Descriptor
deprecated
func (*User) GetLanguage ¶
func (*User) GetLastOnline ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message