dive

Documentation

Index

• Constants
• func ActivityToContext(ctx context.Context, a *Activity) context.Context
• func ActivityToProto(a *Activity) *diveContracts.Activity
• func EventToProto(e Event) *diveContracts.Activity_Event
• func StreamServerInterceptor(master *Master) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(master *Master) grpc.UnaryServerInterceptor
• type Activity
  • func ActivityFromContext(ctx context.Context) *Activity
  • func ActivityFromProto(a *diveContracts.Activity) *Activity
  • func NewBackgroundActivity(req any, jobID string) *Activity
  • func NewStreamGrpcActivity(service string, method string, req any) *Activity
  • func NewUnaryGrpcActivity(service string, method string, req any) *Activity
  • func (a *Activity) AddEvent(name string, ts time.Time, payload map[string]string)
  • func (a *Activity) AddEventNow(name string, payload map[string]string)
  • func (a *Activity) Duration() time.Duration
  • func (a *Activity) Events() []Event
  • func (a *Activity) ID() string
  • func (a *Activity) Props() map[string]string
  • func (a *Activity) Request() any
  • func (a *Activity) SetProp(key string, value string)
  • func (a *Activity) SetProps(props map[string]string)
  • func (a *Activity) SetRequest(req any)
  • func (a *Activity) StartedAt() time.Time
• type Event
  • func EventFromProto(e *diveContracts.Activity_Event) Event
  • func (e Event) ID() string
  • func (e Event) Payload() map[string]string
  • func (e Event) Timestamp() time.Time
• type Events
• type GrpcServer
  • func NewGrpcServer(master *Master) *GrpcServer
  • func (s *GrpcServer) Dive(ctx context.Context, req *diveContracts.DiveRequest) (*diveContracts.DiveResponse, error)
• type Master
  • func NewMaster() *Master
  • func (m *Master) AddActivity(id string, activity *Activity)
  • func (m *Master) GetActivity(id string) *Activity
  • func (m *Master) RemoveActivity(id string)
  • func (m *Master) WalkActivities(cb func(activity *Activity))

Constants

const (
	PropBackgroundJobID = "bg_job_id"
	PropGrpcType        = "grpc_type"
	PropGrpcTypeUnary   = "unary"
	PropGrpcTypeStream  = "stream"
	PropGrpcService     = "grpc_service"
	PropGrpcMethod      = "grpc_method"
)

Functions

func ActivityToContext

func ActivityToContext(ctx context.Context, a *Activity) context.Context

func ActivityToProto

func ActivityToProto(a *Activity) *diveContracts.Activity

func EventToProto

func EventToProto(e Event) *diveContracts.Activity_Event

func StreamServerInterceptor

func StreamServerInterceptor(master *Master) grpc.StreamServerInterceptor

func UnaryServerInterceptor

func UnaryServerInterceptor(master *Master) grpc.UnaryServerInterceptor

Types

type Activity

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

func ActivityFromContext

func ActivityFromContext(ctx context.Context) *Activity

func ActivityFromProto

func ActivityFromProto(a *diveContracts.Activity) *Activity

func NewBackgroundActivity

func NewBackgroundActivity(req any, jobID string) *Activity

func NewStreamGrpcActivity

func NewStreamGrpcActivity(service string, method string, req any) *Activity

func NewUnaryGrpcActivity

func NewUnaryGrpcActivity(service string, method string, req any) *Activity

func (*Activity) AddEvent

func (a *Activity) AddEvent(name string, ts time.Time, payload map[string]string)

func (*Activity) AddEventNow

func (a *Activity) AddEventNow(name string, payload map[string]string)

func (*Activity) Duration

func (a *Activity) Duration() time.Duration

func (*Activity) Events

func (a *Activity) Events() []Event

func (*Activity) ID

func (a *Activity) ID() string

func (*Activity) Props

func (a *Activity) Props() map[string]string

func (*Activity) Request

func (a *Activity) Request() any

func (*Activity) SetProp

func (a *Activity) SetProp(key string, value string)

func (*Activity) SetProps

func (a *Activity) SetProps(props map[string]string)

func (*Activity) SetRequest

func (a *Activity) SetRequest(req any)

func (*Activity) StartedAt

func (a *Activity) StartedAt() time.Time

type Event

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

func EventFromProto

func EventFromProto(e *diveContracts.Activity_Event) Event

func (Event) ID

func (e Event) ID() string

func (Event) Payload

func (e Event) Payload() map[string]string

func (Event) Timestamp

func (e Event) Timestamp() time.Time

type Events

type Events []Event

type GrpcServer

type GrpcServer struct {
	diveContracts.UnimplementedDiveServiceServer
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(master *Master) *GrpcServer

func (*GrpcServer) Dive

func (s *GrpcServer) Dive(ctx context.Context, req *diveContracts.DiveRequest) (*diveContracts.DiveResponse, error)

type Master

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

func NewMaster

func NewMaster() *Master

func (*Master) AddActivity

func (m *Master) AddActivity(id string, activity *Activity)

func (*Master) GetActivity

func (m *Master) GetActivity(id string) *Activity

func (*Master) RemoveActivity

func (m *Master) RemoveActivity(id string)

func (*Master) WalkActivities

func (m *Master) WalkActivities(cb func(activity *Activity))