plugin

Documentation

Index

• Constants
• func RegisterRoute(route Route)
• func Serve()
• type BufferedResponseWriter
  • func NewBufferedResponseWriter() *BufferedResponseWriter
  • func (w *BufferedResponseWriter) Flush() error
  • func (w *BufferedResponseWriter) SetMediaType(mediatype string)
  • func (w *BufferedResponseWriter) Write(b []byte) (int, error)
  • func (w *BufferedResponseWriter) WriteHeader(status gemini.Status, meta string)
• type HandshakeConfig
• type Plugin
• type Request
• type ResponseWriter
• type ResponseWriterImpl
• type Route
• type RoutePlugin
  • func NewRoutePlugin(impl Route) *RoutePlugin
  • func (RoutePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (p *RoutePlugin) Server(*plugin.MuxBroker) (interface{}, error)
• type RouteRPC
  • func (r *RouteRPC) ServeGemini(rr RouteRequest) BufferedResponseWriter
• type RouteRPCServer
  • func (s *RouteRPCServer) ServeGemini(args RouteRequest, resp *BufferedResponseWriter) error
• type RouteReceiver
• type RouteReceiverImpl
  • func (rr *RouteReceiverImpl) ServeGemini(rx RouteRequest) BufferedResponseWriter
• type RouteRequest
• type ServeConfig
• type Status

Constants

const (
	StatusSuccess = gemini.StatusSuccess
)

Functions

func RegisterRoute

func RegisterRoute(route Route)

func Serve

func Serve()

Types

type BufferedResponseWriter

type BufferedResponseWriter struct {
	Mediatype string
	Status    gemini.Status
	Meta      string
	Data      []byte
}

func NewBufferedResponseWriter

func NewBufferedResponseWriter() *BufferedResponseWriter

func (*BufferedResponseWriter) Flush

func (w *BufferedResponseWriter) Flush() error

func (*BufferedResponseWriter) SetMediaType

func (w *BufferedResponseWriter) SetMediaType(mediatype string)

func (*BufferedResponseWriter) Write

func (w *BufferedResponseWriter) Write(b []byte) (int, error)

func (*BufferedResponseWriter) WriteHeader

func (w *BufferedResponseWriter) WriteHeader(status gemini.Status, meta string)

type HandshakeConfig

type HandshakeConfig = plugin.HandshakeConfig

type Plugin

type Plugin = plugin.Plugin

type Request

type Request = gemini.Request

type ResponseWriter

type ResponseWriter = gemini.ResponseWriter

type ResponseWriterImpl

type ResponseWriterImpl struct {
	// contains filtered or unexported fields
}

type Route

type Route interface {
	ServeGemini(ctx context.Context, w ResponseWriter, r *Request)
}

Implementation

type RoutePlugin

type RoutePlugin struct {
	// Impl Injection
	Impl RouteReceiver
}

Plugin implmentation

func NewRoutePlugin

func NewRoutePlugin(impl Route) *RoutePlugin

func (RoutePlugin) Client

func (RoutePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*RoutePlugin) Server

func (p *RoutePlugin) Server(*plugin.MuxBroker) (interface{}, error)

type RouteRPC

type RouteRPC struct {
	// contains filtered or unexported fields
}

Here is an implementation that talks over RPC

func (*RouteRPC) ServeGemini

func (r *RouteRPC) ServeGemini(rr RouteRequest) BufferedResponseWriter

type RouteRPCServer

type RouteRPCServer struct {
	Impl RouteReceiver
}

func (*RouteRPCServer) ServeGemini

func (s *RouteRPCServer) ServeGemini(args RouteRequest, resp *BufferedResponseWriter) error

type RouteReceiver

type RouteReceiver interface {
	ServeGemini(RouteRequest) BufferedResponseWriter
}

type RouteReceiverImpl

type RouteReceiverImpl struct {
	// contains filtered or unexported fields
}

func (*RouteReceiverImpl) ServeGemini

func (rr *RouteReceiverImpl) ServeGemini(rx RouteRequest) BufferedResponseWriter

type RouteRequest

type RouteRequest struct {
	URL string
}

type ServeConfig

type ServeConfig = plugin.ServeConfig

type Status

type Status = gemini.Status