gomicro

Documentation

Index

• Constants
• func BuildGoMicroClientInstrumenter() ...
• func BuildGoMicroServerOtelInstrumenter() ...
• func NewServiceOnEnter(call api.CallContext, opts ...micro.Option)
• func NewV5ClientWrapper(cli client.Client) client.Client
• func NextOnExit(call api.CallContext, nextSelector selector.Next, e error)
• func ServeRequestOnEnter(call api.CallContext, _ interface{}, ctx context.Context, ...)
• func ServeRequestOnExit(call api.CallContext, r error)
• type GoMicroServerAttrsGetter
  • func (n GoMicroServerAttrsGetter) GetErrorType(request goMicroServerRequest, response goMicroResponse, err error) string
  • func (n GoMicroServerAttrsGetter) GetHttpRequestHeader(request goMicroServerRequest, name string) []string
  • func (n GoMicroServerAttrsGetter) GetHttpResponseHeader(request goMicroServerRequest, response goMicroResponse, name string) []string
  • func (n GoMicroServerAttrsGetter) GetHttpResponseStatusCode(request goMicroServerRequest, response goMicroResponse, err error) int
  • func (n GoMicroServerAttrsGetter) GetHttpRoute(request goMicroServerRequest) string
  • func (n GoMicroServerAttrsGetter) GetNetworkLocalInetAddress(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetNetworkLocalPort(request goMicroServerRequest, response goMicroResponse) int
  • func (n GoMicroServerAttrsGetter) GetNetworkPeerInetAddress(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetNetworkPeerPort(request goMicroServerRequest, response goMicroResponse) int
  • func (n GoMicroServerAttrsGetter) GetNetworkProtocolName(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetNetworkProtocolVersion(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetNetworkTransport(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetNetworkType(request goMicroServerRequest, response goMicroResponse) string
  • func (n GoMicroServerAttrsGetter) GetRequestMethod(request goMicroServerRequest) string
  • func (n GoMicroServerAttrsGetter) GetUrlPath(request goMicroServerRequest) string
  • func (n GoMicroServerAttrsGetter) GetUrlQuery(request goMicroServerRequest) string
  • func (n GoMicroServerAttrsGetter) GetUrlScheme(request goMicroServerRequest) string

Constants

const (
	MessageRequest requestType = iota
	CallRequest
	StreamRequest
)

Functions

func BuildGoMicroClientInstrumenter

func BuildGoMicroClientInstrumenter() *instrumenter.PropagatingToDownstreamInstrumenter[goMicroRequest, goMicroResponse]

func BuildGoMicroServerOtelInstrumenter

func BuildGoMicroServerOtelInstrumenter() *instrumenter.PropagatingFromUpstreamInstrumenter[goMicroServerRequest, goMicroResponse]

func NewServiceOnEnter

func NewServiceOnEnter(call api.CallContext, opts ...micro.Option)

func NewV5ClientWrapper

func NewV5ClientWrapper(cli client.Client) client.Client

func NextOnExit

func NextOnExit(call api.CallContext, nextSelector selector.Next, e error)

func ServeRequestOnEnter

func ServeRequestOnEnter(call api.CallContext, _ interface{}, ctx context.Context, request server.Request, response server.Response)

func ServeRequestOnExit

func ServeRequestOnExit(call api.CallContext, r error)

Types

type GoMicroServerAttrsGetter

type GoMicroServerAttrsGetter struct {
}

func (GoMicroServerAttrsGetter) GetErrorType

func (n GoMicroServerAttrsGetter) GetErrorType(request goMicroServerRequest, response goMicroResponse, err error) string

func (GoMicroServerAttrsGetter) GetHttpRequestHeader

func (n GoMicroServerAttrsGetter) GetHttpRequestHeader(request goMicroServerRequest, name string) []string

func (GoMicroServerAttrsGetter) GetHttpResponseHeader

func (n GoMicroServerAttrsGetter) GetHttpResponseHeader(request goMicroServerRequest, response goMicroResponse, name string) []string

func (GoMicroServerAttrsGetter) GetHttpResponseStatusCode

func (n GoMicroServerAttrsGetter) GetHttpResponseStatusCode(request goMicroServerRequest, response goMicroResponse, err error) int

func (GoMicroServerAttrsGetter) GetHttpRoute

func (n GoMicroServerAttrsGetter) GetHttpRoute(request goMicroServerRequest) string

func (GoMicroServerAttrsGetter) GetNetworkLocalInetAddress

func (n GoMicroServerAttrsGetter) GetNetworkLocalInetAddress(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetNetworkLocalPort

func (n GoMicroServerAttrsGetter) GetNetworkLocalPort(request goMicroServerRequest, response goMicroResponse) int

func (GoMicroServerAttrsGetter) GetNetworkPeerInetAddress

func (n GoMicroServerAttrsGetter) GetNetworkPeerInetAddress(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetNetworkPeerPort

func (n GoMicroServerAttrsGetter) GetNetworkPeerPort(request goMicroServerRequest, response goMicroResponse) int

func (GoMicroServerAttrsGetter) GetNetworkProtocolName

func (n GoMicroServerAttrsGetter) GetNetworkProtocolName(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetNetworkProtocolVersion

func (n GoMicroServerAttrsGetter) GetNetworkProtocolVersion(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetNetworkTransport

func (n GoMicroServerAttrsGetter) GetNetworkTransport(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetNetworkType

func (n GoMicroServerAttrsGetter) GetNetworkType(request goMicroServerRequest, response goMicroResponse) string

func (GoMicroServerAttrsGetter) GetRequestMethod

func (n GoMicroServerAttrsGetter) GetRequestMethod(request goMicroServerRequest) string

func (GoMicroServerAttrsGetter) GetUrlPath

func (n GoMicroServerAttrsGetter) GetUrlPath(request goMicroServerRequest) string

func (GoMicroServerAttrsGetter) GetUrlQuery

func (n GoMicroServerAttrsGetter) GetUrlQuery(request goMicroServerRequest) string

func (GoMicroServerAttrsGetter) GetUrlScheme

func (n GoMicroServerAttrsGetter) GetUrlScheme(request goMicroServerRequest) string