Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package

Go to main page

Versions in this module

v4

v4.1.0

Jul 6, 2021

Changes in this version

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

type HttpRequest

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

v4.0.0

Oct 3, 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-bot/v5