internal

Documentation

Index

• type ConnPool
  • func NewConnPool(logger logrus.FieldLogger, dialer contextDialer) *ConnPool
  • func (c *ConnPool) GetClientConn(ctx context.Context, destination string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error)
• type Message
• type MessageOrigin
• type RPC
  • func (r RPC) StreamName() string
• type Status

Types

type ConnPool

type ConnPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewConnPool

func NewConnPool(logger logrus.FieldLogger, dialer contextDialer) *ConnPool

func (*ConnPool) GetClientConn

func (c *ConnPool) GetClientConn(ctx context.Context, destination string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error)

type Message

type Message struct {
	MessageOrigin MessageOrigin `json:"message_origin,omitempty"`
	RawMessage    []byte        `json:"raw_message"`
	Message       interface{}   `json:"message,omitempty"`
	Timestamp     time.Time     `json:"timestamp"`
}

type MessageOrigin

type MessageOrigin string

const (
	ClientMessage MessageOrigin = "client"
	ServerMessage MessageOrigin = "server"
)

type RPC

type RPC struct {
	Service              string      `json:"service"`
	Method               string      `json:"method"`
	Messages             []*Message  `json:"messages"`
	Status               *Status     `json:"error,omitempty"`
	Metadata             metadata.MD `json:"metadata"`
	MetadataRespHeaders  metadata.MD `json:"metadata_response_headers"`
	MetadataRespTrailers metadata.MD `json:"metadata_response_trailers"`
}

func (RPC) StreamName

func (r RPC) StreamName() string

type Status

type Status struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}