micro

Documentation

Index

• Constants
• type ClientWrapper
• type LocalClient
  • func NewLocalClient(microClient client.Client, microRegistry registry.Registry, ...) LocalClient
  • func (c LocalClient) Call(ctx context.Context, env, service, endpoint string, ...) error
  • func (c LocalClient) GetService(env, name string) (*registry.Service, error)
  • func (c LocalClient) ListEnvs() []string
  • func (c LocalClient) ListServices(env string) ([]*registry.Service, error)
• type MultiWebClient
  • func NewMultiWebClient(envs map[string]string) MultiWebClient
  • func (c MultiWebClient) Call(ctx context.Context, env, service, endpoint string, ...) error
  • func (c MultiWebClient) GetService(env, name string) (*registry.Service, error)
  • func (c MultiWebClient) ListEnvs() []string
  • func (c MultiWebClient) ListServices(env string) ([]*registry.Service, error)
• type WebClient
  • func NewWebClient(baseUri, tokenContextKey string) WebClient
  • func (c *WebClient) Call(ctx context.Context, req client.Request, rsp interface{}, ...) error
  • func (c *WebClient) GetService(ctx context.Context, name string) (*registry.Service, error)
  • func (c *WebClient) Init(...client.Option) error
  • func (c *WebClient) ListServices(ctx context.Context) ([]*registry.Service, error)
  • func (c *WebClient) NewMessage(topic string, msg interface{}, opts ...client.MessageOption) client.Message
  • func (c *WebClient) NewRequest(service, endpoint string, req interface{}, reqOpts ...client.RequestOption) client.Request
  • func (c *WebClient) Options() client.Options
  • func (c *WebClient) Publish(_ context.Context, _ client.Message, _ ...client.PublishOption) error
  • func (c *WebClient) Stream(_ context.Context, _ client.Request, _ ...client.CallOption) (client.Stream, error)
  • func (c *WebClient) String() string

Constants

const DefaultTokenContextKey = "X-MicroWeb-Token"

const EnvLocal = "local"

Types

type ClientWrapper

type ClientWrapper interface {
	ListEnvs() []string
	ListServices(env string) ([]*registry.Service, error)
	GetService(env, name string) (*registry.Service, error)
	Call(ctx context.Context, env, service, endpoint string, body map[string]interface{}, resp *json.RawMessage) error
}

type LocalClient

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

func NewLocalClient

func NewLocalClient(microClient client.Client, microRegistry registry.Registry, requestTimeout time.Duration) LocalClient

func (LocalClient) Call

func (c LocalClient) Call(ctx context.Context, env, service, endpoint string, body map[string]interface{}, response *json.RawMessage) error

func (LocalClient) GetService

func (c LocalClient) GetService(env, name string) (*registry.Service, error)

func (LocalClient) ListEnvs

func (c LocalClient) ListEnvs() []string

func (LocalClient) ListServices

func (c LocalClient) ListServices(env string) ([]*registry.Service, error)

type MultiWebClient

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

func NewMultiWebClient

func NewMultiWebClient(envs map[string]string) MultiWebClient

func (MultiWebClient) Call

func (c MultiWebClient) Call(ctx context.Context, env, service, endpoint string, body map[string]interface{}, response *json.RawMessage) error

func (MultiWebClient) GetService

func (c MultiWebClient) GetService(env, name string) (*registry.Service, error)

func (MultiWebClient) ListEnvs

func (c MultiWebClient) ListEnvs() []string

func (MultiWebClient) ListServices

func (c MultiWebClient) ListServices(env string) ([]*registry.Service, error)

type WebClient

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

func NewWebClient

func NewWebClient(baseUri, tokenContextKey string) WebClient

func (*WebClient) Call

func (c *WebClient) Call(ctx context.Context, req client.Request, rsp interface{}, _ ...client.CallOption) error

func (*WebClient) GetService

func (c *WebClient) GetService(ctx context.Context, name string) (*registry.Service, error)

func (*WebClient) Init

func (c *WebClient) Init(...client.Option) error

func (*WebClient) ListServices

func (c *WebClient) ListServices(ctx context.Context) ([]*registry.Service, error)

func (*WebClient) NewMessage

func (c *WebClient) NewMessage(topic string, msg interface{}, opts ...client.MessageOption) client.Message

func (*WebClient) NewRequest

func (c *WebClient) NewRequest(service, endpoint string, req interface{}, reqOpts ...client.RequestOption) client.Request

func (*WebClient) Options

func (c *WebClient) Options() client.Options

func (*WebClient) Publish

func (c *WebClient) Publish(_ context.Context, _ client.Message, _ ...client.PublishOption) error

func (*WebClient) Stream

func (c *WebClient) Stream(_ context.Context, _ client.Request, _ ...client.CallOption) (client.Stream, error)

func (*WebClient) String

func (c *WebClient) String() string