gactus

Jan 21, 2020

Changes in this version

+ type GactusCore interface

+ Start func()

+ Wait func()

+ func NewGactusCore(httpPort, tcpPort int, accessKey string) GactusCore

+ type GactusService interface

+ RegisterProcessors func(processors []*Processor) error

+ SendRequest func(ctx context.Context, command string, req proto.Message, res proto.Message) error

+ Start func()

+ Wait func()

+ func NewGactusService(name string, tcpPort int, coreAddress, accessKey string) GactusService

Dec 8, 2019

Changes in this version

+ const CoreAccessToken

+ const ServiceAccessToken

Oct 26, 2019

Changes in this version

+ const DefaultServiceReadTimeout

+ const ServiceReadTimeoutVar

Oct 26, 2019

Changes in this version

+ const DefaultServiceClearPeriod

+ const DefaultServiceIdleConnTimeout

+ const DefaultServiceMaxConns

+ const DefaultServiceMinConns

+ const DefaultServiceTCPPort

+ const DefaultServiceWaitConnTimeout

+ const ServiceClearPeriodVar

+ const ServiceIdleConnTimeoutVar

+ const ServiceMaxConnsVar

+ const ServiceMinConnsVar

+ const ServiceNameVar

+ const ServiceWaitConnTimeoutVar

type Core

+ func NewCoreWithConfig(httpPort, tcpPort, healthCheckInterval int) Core

type Service

+ func NewServiceWithConfig(name, coreAddr string, ...) (Service, error)

Oct 23, 2019

Changes in this version

type Processor

+ HTTPMiddleware func(ctx context.Context, header map[string]string, req, res proto.Message)

Oct 21, 2019

Changes in this version

+ const CoreDefaultHealthCheckIntervalVar

+ const CoreHTTPPortVar

+ const CoreTCPPortVar

+ const DefaultCoreHTTPPort

+ const DefaultCoreTCPPort

+ const DefaultHealthCheckInterval

+ const ServiceCoreAddrVar

+ const ServiceTCPPortVar

+ type Core interface

+ Start func()

+ Wait func()

+ func NewCore(httpPort, tcpPort, healthCheckInterval int) Core

+ type Processor struct

+ Command string

+ HTTPConfig *pb.HttpConfig

+ Process func(ctx context.Context, req, res proto.Message) (code uint32)

+ Req proto.Message

+ Res proto.Message

+ type Service interface

+ RegisterService func(processors []*Processor) (err error)

+ SendRequest func(ctx context.Context, command string, req, res proto.Message) (code uint32)

+ Start func()

+ Wait func()

+ func NewService(name, coreAddr string, ...) (Service, error)