Versions in this module Expand all Collapse all v3 v3.0.1 Sep 29, 2020 v3.0.0 Sep 29, 2020 Changes in this version + func ConvertFromRPCHeaders(headers []*HttpHeader) http.Header + 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 *zap.SugaredLogger) *httpServer + func RegisterHTTPPluginServer(s *grpc.Server, srv HTTPPluginServer) + func RegisterIRCPluginServer(s *grpc.Server, srv IRCPluginServer) + type Channel struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Channel) Descriptor() ([]byte, []int) + func (*Channel) ProtoMessage() + func (m *Channel) GetName() string + func (m *Channel) Reset() + func (m *Channel) String() string + func (m *Channel) XXX_DiscardUnknown() + func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Channel) XXX_Merge(src proto.Message) + func (m *Channel) XXX_Size() int + func (m *Channel) XXX_Unmarshal(b []byte) error + type ChannelMessage struct + Channel string + Message string + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChannelMessage) Descriptor() ([]byte, []int) + func (*ChannelMessage) ProtoMessage() + func (m *ChannelMessage) GetChannel() string + func (m *ChannelMessage) GetMessage() string + func (m *ChannelMessage) GetSource() string + func (m *ChannelMessage) Reset() + func (m *ChannelMessage) String() string + func (m *ChannelMessage) XXX_DiscardUnknown() + func (m *ChannelMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChannelMessage) XXX_Merge(src proto.Message) + func (m *ChannelMessage) XXX_Size() int + func (m *ChannelMessage) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type Error struct + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) Reset() + func (m *Error) String() string + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type GrpcServer struct + func NewGrpcServer(conn *irc.Connection, eventManager *irc.EventManager, rpcPort int, ...) GrpcServer + func (s *GrpcServer) StartGRPC() + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func ConvertToRPCHeaders(headers http.Header) []*HttpHeader + func (*HttpHeader) Descriptor() ([]byte, []int) + func (*HttpHeader) ProtoMessage() + func (m *HttpHeader) GetKey() string + func (m *HttpHeader) GetValue() string + func (m *HttpHeader) Reset() + func (m *HttpHeader) String() string + func (m *HttpHeader) XXX_DiscardUnknown() + func (m *HttpHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HttpHeader) XXX_Merge(src proto.Message) + func (m *HttpHeader) XXX_Size() int + func (m *HttpHeader) XXX_Unmarshal(b []byte) error + type HttpRequest struct + Body []byte + Header []*HttpHeader + Method string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HttpRequest) Descriptor() ([]byte, []int) + func (*HttpRequest) ProtoMessage() + func (m *HttpRequest) GetBody() []byte + func (m *HttpRequest) GetHeader() []*HttpHeader + func (m *HttpRequest) GetMethod() string + func (m *HttpRequest) GetPath() string + func (m *HttpRequest) Reset() + func (m *HttpRequest) String() string + func (m *HttpRequest) XXX_DiscardUnknown() + func (m *HttpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HttpRequest) XXX_Merge(src proto.Message) + func (m *HttpRequest) XXX_Size() int + func (m *HttpRequest) XXX_Unmarshal(b []byte) error + type HttpResponse struct + Body []byte + Header []*HttpHeader + Status int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HttpResponse) Descriptor() ([]byte, []int) + func (*HttpResponse) ProtoMessage() + func (m *HttpResponse) GetBody() []byte + func (m *HttpResponse) GetHeader() []*HttpHeader + func (m *HttpResponse) GetStatus() int32 + func (m *HttpResponse) Reset() + func (m *HttpResponse) String() string + func (m *HttpResponse) XXX_DiscardUnknown() + func (m *HttpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HttpResponse) XXX_Merge(src proto.Message) + func (m *HttpResponse) XXX_Size() int + func (m *HttpResponse) XXX_Unmarshal(b []byte) error + type IRCPluginClient interface + GetMessages func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (IRCPlugin_GetMessagesClient, 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 + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawMessage) Descriptor() ([]byte, []int) + func (*RawMessage) ProtoMessage() + func (m *RawMessage) GetMessage() string + func (m *RawMessage) Reset() + func (m *RawMessage) String() string + func (m *RawMessage) XXX_DiscardUnknown() + func (m *RawMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RawMessage) XXX_Merge(src proto.Message) + func (m *RawMessage) XXX_Size() int + func (m *RawMessage) XXX_Unmarshal(b []byte) error + type Route struct + Prefix string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Route) Descriptor() ([]byte, []int) + func (*Route) ProtoMessage() + func (m *Route) GetPrefix() string + func (m *Route) Reset() + func (m *Route) String() string + func (m *Route) XXX_DiscardUnknown() + func (m *Route) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Route) XXX_Merge(src proto.Message) + func (m *Route) XXX_Size() int + func (m *Route) XXX_Unmarshal(b []byte) error + type UnimplementedHTTPPluginServer struct + func (*UnimplementedHTTPPluginServer) GetRequest(srv HTTPPlugin_GetRequestServer) error + type UnimplementedIRCPluginServer struct + func (*UnimplementedIRCPluginServer) GetMessages(req *Channel, srv IRCPlugin_GetMessagesServer) error + func (*UnimplementedIRCPluginServer) Ping(ctx context.Context, req *Empty) (*Empty, error) + func (*UnimplementedIRCPluginServer) SendChannelMessage(ctx context.Context, req *ChannelMessage) (*Error, error) + func (*UnimplementedIRCPluginServer) SendRawMessage(ctx context.Context, req *RawMessage) (*Error, error) Other modules containing this package github.com/greboid/irc github.com/greboid/irc/v2
Go to main page