kuja

package module

v0.0.0-...-8a04a08 Latest Latest Go to latest Published: Sep 12, 2015 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/plimble/kuja

Links

Open Source Insights

README ¶

Kuja

Go webservice framework

##Features

Client
- Sync/Async Requests
- Publish
- Service Discovery/Watch
- Encoder
- Circuit breaker
Server
- RPC HTTP
- Publish/Subscribe Queue
- Retries/Timeout Queue
- Graceful Shutdown with timeout
- Custom Error
- Register Etcd/Consul and Hartbeat
- Snappy
- Encoder
- Middleware
- Health Endpoint (/health)
- Metric

##TODO

Circuit breaker Metric
Metric
Doc
Test

##Plan

HTTP2

##Usage See in example

Documentation ¶

Index ¶

Constants
type Context
- func (ctx *Context) Next() error
type Handler
type Metadata
type Server
- func NewServer() *Server
type ServiceErrorFunc
type SubscribeContext
- func (ctx *SubscribeContext) Ack() error
- func (ctx *SubscribeContext) Reject(retry int, err error) error
type SubscriberErrorFunc

Constants ¶

View Source

const (
	DEVELOPMENT = "development"
	STAGING     = "staging"
	PRODUCTION  = "production"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Context ¶

type Context struct {
	ReqMetadata  Metadata
	RespMetadata Metadata

	ServiceID   string
	ServiceName string
	MethodName  string
	// contains filtered or unexported fields
}

func (*Context) Next ¶

func (ctx *Context) Next() error

type Handler ¶

type Handler func(ctx *Context, w http.ResponseWriter, r *http.Request) error

type Metadata ¶

type Metadata map[string]string

type Server ¶

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

func NewServer ¶

func NewServer() *Server

func (*Server) Broker ¶

func (server *Server) Broker(b broker.Broker)

func (*Server) Close ¶

func (server *Server) Close()

func (*Server) Encoder ¶

func (server *Server) Encoder(enc encoder.Encoder)

func (*Server) Id ¶

func (server *Server) Id() string

func (*Server) Registry ¶

func (server *Server) Registry(r registry.Registry)

func (*Server) Run ¶

func (server *Server) Run(addr string, timeout time.Duration)

func (*Server) RunTLS ¶

func (server *Server) RunTLS(addr string, timeout time.Duration, certFile, keyFile string)

func (*Server) ServeHTTP ¶

func (server *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*Server) ServePubSub ¶

func (server *Server) ServePubSub(topic string, msg []byte) error

func (*Server) Service ¶

func (server *Server) Service(service interface{}, h ...Handler)

func (*Server) ServiceError ¶

func (server *Server) ServiceError(fn ServiceErrorFunc)

func (*Server) Snappy ¶

func (server *Server) Snappy(enable bool)

func (*Server) Stage ¶

func (server *Server) Stage(stage string)

func (server *Server) Subscribe(topic, queue string, timeout time.Duration, size int, method interface{})

func (*Server) SubscriberError ¶

func (server *Server) SubscriberError(fn SubscriberErrorFunc)

func (*Server) Use ¶

func (server *Server) Use(h ...Handler)

type ServiceErrorFunc ¶

type ServiceErrorFunc func(serviceID, service, method string, status int, err error)

type SubscribeContext ¶

type SubscribeContext struct {
	Id       string
	Topic    string
	Metadata Metadata

	Queue string
	// contains filtered or unexported fields
}

func (*SubscribeContext) Ack ¶

func (ctx *SubscribeContext) Ack() error

func (*SubscribeContext) Reject ¶

func (ctx *SubscribeContext) Reject(retry int, err error) error

type SubscriberErrorFunc ¶

type SubscriberErrorFunc func(appId, topic, queue string, err error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
broker Package broker is a generated protocol buffer package.	Package broker is a generated protocol buffer package.
http
nats
rabbitmq
stub_broker
client
mock_client
stub_client
contract
encoder
gogoproto
json
msgp
proto
example
middleware
middleware/client
middleware/server
protobuf Package proto is a generated protocol buffer package.	Package proto is a generated protocol buffer package.
protobuf/client
protobuf/server
pubsub
pubsub/client
pubsub/server
registry
registry/client
registry/server
reqresp
reqresp/client
reqresp/server
tls
tls/client
tls/server
registry
consul
etcd
stub_registry

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