micro/micro.go

package micro

import (
	"context"
)

type (
	applicationKey struct {
	}

	HandleOptions struct {
		HttpMethod  string
		DisableRpc  bool
		DisableHttp bool
	}

	HandleOption func(o *HandleOptions)

	HandleFunc func(ctx Context) (err error)


	Application interface {
		Handle(method string, cb HandleFunc, opts ...HandleOption)                     //注册一个处理器
		CreateRequest(name, method string, body interface{}) (req *Request, err error) //创建一个rpc请求
	}

	Server interface {
		Start(ctx context.Context) (err error)
		Stop() (err error)
	}
)

var (
	contextKey = applicationKey{}
)

func FromContext(ctx context.Context) Application {
	if v := ctx.Value(contextKey); v != nil {
		return v.(Application)
	}
	return nil
}

func WithContext(ctx context.Context, app Application) context.Context {
	return context.WithValue(ctx, contextKey, app)
}