client

Documentation

Index

• Constants
• func Emit(ctx context.Context, client grpc.EventsClient, callback Callable, ...) error
• func PrepareEvent(ctx context.Context, event *pb.Event)
• type Callable
• type EventClient
• type EventClientCallback
  • func NewEventClientCallback(stream grpc.Events_EmitClient) *EventClientCallback
  • func (e EventClientCallback) Callback()
  • func (e EventClientCallback) GetCommChannel() chan *pb2.StatusResponse
  • func (e EventClientCallback) GetWaitChannel() chan struct{}
  • func (e EventClientCallback) RegisterCommunicationsChannel(comm chan *pb2.StatusResponse)
  • func (e EventClientCallback) SetWaitChannel(in chan struct{})

Constants

const (
	KeyTraceId    = "trace-id"
	KeyParentId   = "parent-id"
	KeyTraceFlags = "trace-flags"
)

Functions

func Emit

func Emit(ctx context.Context,
	client grpc.EventsClient,
	callback Callable,
	events ...*pb.Event) error

func PrepareEvent

func PrepareEvent(ctx context.Context, event *pb.Event)

Types

type Callable

type Callable interface {
	Callable()
	GetWaitChannel() chan struct{}
	GetCommChannel() chan *pb2.StatusResponse
}

type EventClient

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

type EventClientCallback

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

func NewEventClientCallback

func NewEventClientCallback(stream grpc.Events_EmitClient) *EventClientCallback

func (EventClientCallback) Callback

func (e EventClientCallback) Callback()

func (EventClientCallback) GetCommChannel

func (e EventClientCallback) GetCommChannel() chan *pb2.StatusResponse

func (EventClientCallback) GetWaitChannel

func (e EventClientCallback) GetWaitChannel() chan struct{}

func (EventClientCallback) RegisterCommunicationsChannel

func (e EventClientCallback) RegisterCommunicationsChannel(comm chan *pb2.StatusResponse)

func (EventClientCallback) SetWaitChannel

func (e EventClientCallback) SetWaitChannel(in chan struct{})