client

Documentation

Index

• Variables
• func NewContext(ctx context.Context, s IClient) context.Context
• type Event
• type IClient
  • func FromContext(ctx context.Context) (IClient, bool)
• type Option
  • func AfterStart(fn func() error) Option
  • func AfterStop(fn func() error) Option
  • func BeforeStart(fn func() error) Option
  • func BeforeStop(fn func() error) Option
  • func Context1(ctx context.Context) Option
  • func HandleSignal(b bool) Option
• type Options
• type Publisher

Variables

var (
	Opts = new(struct {
		Dev         bool // 是否开发模式
		Port        int
		ServerID    int
		Channel     string
		Daemon      bool
		CfgFilepath string
	})
)

Functions

func NewContext

func NewContext(ctx context.Context, s IClient) context.Context

Types

type Event

type Event interface {
	Publish(ctx context.Context, msg interface{}) error
}

type IClient

type IClient interface {
	Name() string
	Init(...Option)
	Options() Options
	Run() error
	Stop() error
}

func FromContext

func FromContext(ctx context.Context) (IClient, bool)

type Option

type Option func(*Options)

func AfterStart

func AfterStart(fn func() error) Option

func AfterStop

func AfterStop(fn func() error) Option

func BeforeStart

func BeforeStart(fn func() error) Option

func BeforeStop

func BeforeStop(fn func() error) Option

func Context1

func Context1(ctx context.Context) Option

func HandleSignal

func HandleSignal(b bool) Option

type Options

type Options struct {
	Rds         *redis.Store
	BeforeStart []func() error
	BeforeStop  []func() error
	AfterStart  []func() error
	AfterStop   []func() error

	Context context.Context
	Cancel  context.CancelFunc

	Signal bool
}

type Publisher

type Publisher = Event