rpc

package

Go to main page

Versions in this module

v5

v5.0.7

Oct 29, 2023

v5.0.6

Apr 15, 2022

v5.0.5

Feb 1, 2022

v5.0.4

Sep 19, 2021

v5.0.3

Sep 19, 2021

Changes in this version

type IRCPluginClient

+ SendRelayMessage func(ctx context.Context, in *RelayMessage, opts ...grpc.CallOption) (*Error, error)

type IRCPluginServer

+ SendRelayMessage func(context.Context, *RelayMessage) (*Error, error)

type IRCSender

+ SendRelayMessage func(channel string, nickname string, message string) error

+ type RelayMessage struct

+ Channel string

+ Message string

+ Nick string

+ Tags map[string]string

+ func (*RelayMessage) Descriptor() ([]byte, []int)

+ func (*RelayMessage) ProtoMessage()

+ func (x *RelayMessage) GetChannel() string

+ func (x *RelayMessage) GetMessage() string

+ func (x *RelayMessage) GetNick() string

+ func (x *RelayMessage) GetTags() map[string]string

+ func (x *RelayMessage) ProtoReflect() protoreflect.Message

+ func (x *RelayMessage) Reset()

+ func (x *RelayMessage) String() string

type UnimplementedIRCPluginServer

+ func (UnimplementedIRCPluginServer) SendRelayMessage(context.Context, *RelayMessage) (*Error, error)

v5.0.2

Sep 2, 2021

v5.0.1

Aug 27, 2021

Changes in this version

+ type IRCFunctions interface

+ AddCallback func(string, func(ircmsg.Message)) ircevent.CallbackID

+ CurrentNick func() string

+ GetChannels func() []string

+ RemoveCallback func(id ircevent.CallbackID)

+ type IRCSender interface

+ Join func(string) error

+ Part func(string) error

+ SendRawf func(string, ...interface{}) error

v5.0.0

Aug 26, 2021

Changes in this version

+ var File_plugin_proto protoreflect.FileDescriptor

+ var HTTPPlugin_ServiceDesc = grpc.ServiceDesc

+ var IRCPlugin_ServiceDesc = grpc.ServiceDesc

+ func ConvertFromRPCHeaders(headers []*HttpHeader) http.Header

+ func ConvertRPCToHTTP(r *HttpRequest) *http.Request

+ func CtxWithToken(ctx context.Context, scheme string, token string) context.Context

+ func CtxWithTokenAndPath(ctx context.Context, scheme string, token string, path string) context.Context

+ func NewHttpServer(port int, plugin []Plugin, logger irc.Logger) *httpServer

+ func RegisterHTTPPluginServer(s grpc.ServiceRegistrar, srv HTTPPluginServer)

+ func RegisterIRCPluginServer(s grpc.ServiceRegistrar, srv IRCPluginServer)

+ type Channel struct

+ Name string

+ func (*Channel) Descriptor() ([]byte, []int)

+ func (*Channel) ProtoMessage()

+ func (x *Channel) GetName() string

+ func (x *Channel) ProtoReflect() protoreflect.Message

+ func (x *Channel) Reset()

+ func (x *Channel) String() string

+ type ChannelList struct

+ Name []string

+ func (*ChannelList) Descriptor() ([]byte, []int)

+ func (*ChannelList) ProtoMessage()

+ func (x *ChannelList) GetName() []string

+ func (x *ChannelList) ProtoReflect() protoreflect.Message

+ func (x *ChannelList) Reset()

+ func (x *ChannelList) String() string

+ type ChannelMessage struct

+ Channel string

+ Message string

+ Source string

+ Tags map[string]string

+ func (*ChannelMessage) Descriptor() ([]byte, []int)

+ func (*ChannelMessage) ProtoMessage()

+ func (x *ChannelMessage) GetChannel() string

+ func (x *ChannelMessage) GetMessage() string

+ func (x *ChannelMessage) GetSource() string

+ func (x *ChannelMessage) GetTags() map[string]string

+ func (x *ChannelMessage) ProtoReflect() protoreflect.Message

+ func (x *ChannelMessage) Reset()

+ func (x *ChannelMessage) String() string

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type Error struct

+ Message string

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (x *Error) GetMessage() string

+ func (x *Error) ProtoReflect() protoreflect.Message

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ type GrpcServer struct

+ func NewGrpcServer(rpcPort int, pluginString string, webPort int, logger irc.Logger) (*GrpcServer, error)

+ func (s *GrpcServer) StartGRPC(bot *bot.Bot)

+ type HTTPPluginClient interface

+ GetRequest func(ctx context.Context, opts ...grpc.CallOption) (HTTPPlugin_GetRequestClient, error)

+ func NewHTTPPluginClient(cc grpc.ClientConnInterface) HTTPPluginClient

+ type HTTPPluginServer interface

+ GetRequest func(HTTPPlugin_GetRequestServer) error

+ type HTTPPlugin_GetRequestClient interface

+ Recv func() (*HttpRequest, error)

+ Send func(*HttpResponse) error

+ type HTTPPlugin_GetRequestServer interface

+ Recv func() (*HttpResponse, error)

+ Send func(*HttpRequest) error

+ type HttpHeader struct

+ Key string

+ Value string

+ func ConvertToRPCHeaders(headers http.Header) []*HttpHeader

+ func (*HttpHeader) Descriptor() ([]byte, []int)

+ func (*HttpHeader) ProtoMessage()

+ func (x *HttpHeader) GetKey() string

+ func (x *HttpHeader) GetValue() string

+ func (x *HttpHeader) ProtoReflect() protoreflect.Message

+ func (x *HttpHeader) Reset()

+ func (x *HttpHeader) String() string

+ type HttpRequest struct

+ Body []byte

+ Header []*HttpHeader

+ Method string

+ Path string

+ func ConvertHTTPToRPC(r *http.Request) (*HttpRequest, error)

+ func (*HttpRequest) Descriptor() ([]byte, []int)

+ func (*HttpRequest) ProtoMessage()

+ func (x *HttpRequest) GetBody() []byte

+ func (x *HttpRequest) GetHeader() []*HttpHeader

+ func (x *HttpRequest) GetMethod() string

+ func (x *HttpRequest) GetPath() string

+ func (x *HttpRequest) ProtoReflect() protoreflect.Message

+ func (x *HttpRequest) Reset()

+ func (x *HttpRequest) String() string

+ type HttpResponse struct

+ Body []byte

+ Header []*HttpHeader

+ Status int32

+ func (*HttpResponse) Descriptor() ([]byte, []int)

+ func (*HttpResponse) ProtoMessage()

+ func (x *HttpResponse) GetBody() []byte

+ func (x *HttpResponse) GetHeader() []*HttpHeader

+ func (x *HttpResponse) GetStatus() int32

+ func (x *HttpResponse) ProtoReflect() protoreflect.Message

+ func (x *HttpResponse) Reset()

+ func (x *HttpResponse) String() string

+ type IRCPluginClient interface

+ GetMessages func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (IRCPlugin_GetMessagesClient, error)

+ JoinChannel func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*Error, error)

+ LeaveChannel func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*Error, error)

+ ListChannel func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelList, error)

+ Ping func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ SendChannelMessage func(ctx context.Context, in *ChannelMessage, opts ...grpc.CallOption) (*Error, error)

+ SendRawMessage func(ctx context.Context, in *RawMessage, opts ...grpc.CallOption) (*Error, error)

+ func NewIRCPluginClient(cc grpc.ClientConnInterface) IRCPluginClient

+ type IRCPluginServer interface

+ GetMessages func(*Channel, IRCPlugin_GetMessagesServer) error

+ JoinChannel func(context.Context, *Channel) (*Error, error)

+ LeaveChannel func(context.Context, *Channel) (*Error, error)

+ ListChannel func(context.Context, *Empty) (*ChannelList, error)

+ Ping func(context.Context, *Empty) (*Empty, error)

+ SendChannelMessage func(context.Context, *ChannelMessage) (*Error, error)

+ SendRawMessage func(context.Context, *RawMessage) (*Error, error)

+ type IRCPlugin_GetMessagesClient interface

+ Recv func() (*ChannelMessage, error)

+ type IRCPlugin_GetMessagesServer interface

+ Send func(*ChannelMessage) error

+ type Plugin struct

+ Name string

+ Token string

+ func ParsePluginString(pluginString string) (plugins []Plugin, err error)

+ type RawMessage struct

+ Message string

+ func (*RawMessage) Descriptor() ([]byte, []int)

+ func (*RawMessage) ProtoMessage()

+ func (x *RawMessage) GetMessage() string

+ func (x *RawMessage) ProtoReflect() protoreflect.Message

+ func (x *RawMessage) Reset()

+ func (x *RawMessage) String() string

+ type Route struct

+ Prefix string

+ func (*Route) Descriptor() ([]byte, []int)

+ func (*Route) ProtoMessage()

+ func (x *Route) GetPrefix() string

+ func (x *Route) ProtoReflect() protoreflect.Message

+ func (x *Route) Reset()

+ func (x *Route) String() string

+ type UnimplementedHTTPPluginServer struct

+ func (UnimplementedHTTPPluginServer) GetRequest(HTTPPlugin_GetRequestServer) error

+ type UnimplementedIRCPluginServer struct

+ func (UnimplementedIRCPluginServer) GetMessages(*Channel, IRCPlugin_GetMessagesServer) error

+ func (UnimplementedIRCPluginServer) JoinChannel(context.Context, *Channel) (*Error, error)

+ func (UnimplementedIRCPluginServer) LeaveChannel(context.Context, *Channel) (*Error, error)

+ func (UnimplementedIRCPluginServer) ListChannel(context.Context, *Empty) (*ChannelList, error)

+ func (UnimplementedIRCPluginServer) Ping(context.Context, *Empty) (*Empty, error)

+ func (UnimplementedIRCPluginServer) SendChannelMessage(context.Context, *ChannelMessage) (*Error, error)

+ func (UnimplementedIRCPluginServer) SendRawMessage(context.Context, *RawMessage) (*Error, error)

+ type UnsafeHTTPPluginServer interface

+ type UnsafeIRCPluginServer interface

Other modules containing this package

github.com/greboid/irc-bot/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL