rpc

package

Go to main page

Versions in this module

v1

v1.3.1

Mar 31, 2020

Changes in this version

type GrpcServer

+ func NewGrpcServer(conn *irc.Connection, eventManager *irc.EventManager, rpcPort int, ...) GrpcServer

v1.3.0

Mar 30, 2020

Changes in this version

type GrpcServer

+ EventManager irc.EventManager

v1.2.0

Mar 21, 2020

v1.1.0

Mar 18, 2020

Changes in this version

+ type Plugin struct

+ Name string

+ Token string

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

v1.0.0

Mar 15, 2020

Changes in this version

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

+ 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

+ Conn *irc.Connection

+ DB *database.DB

+ Plugins []database.Plugin

+ RPCPort int

+ func (s *GrpcServer) StartGRPC()

+ 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 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 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/v2

github.com/greboid/irc/v3

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