endpoint

Documentation

Index

• type DefaultEndpoint
  • func NewDefaultEndpoint(ctx context.Context, address string, kvs ...string) (*DefaultEndpoint, error)
  • func (e *DefaultEndpoint) Call(ctx context.Context, data []byte) ([]byte, error)
  • func (e *DefaultEndpoint) Close() error
  • func (e *DefaultEndpoint) Name() string

Types

type DefaultEndpoint

type DefaultEndpoint struct {
	Address    string
	Attributes map[string]string
	// contains filtered or unexported fields
}

func NewDefaultEndpoint

func NewDefaultEndpoint(ctx context.Context, address string, kvs ...string) (*DefaultEndpoint, error)

func (*DefaultEndpoint) Call

func (e *DefaultEndpoint) Call(ctx context.Context, data []byte) ([]byte, error)

func (*DefaultEndpoint) Close

func (e *DefaultEndpoint) Close() error

func (*DefaultEndpoint) Name

func (e *DefaultEndpoint) Name() string