apiutil

Documentation

Index

• func AgentMetaFromContext(ctx context.Context) *api.AgentMeta
• func AgentMetaFromRawContext(ctx context.Context) (*api.AgentMeta, error)
• func AgentTokenFromContext(ctx context.Context) api.AgentToken
• func InjectAgentMeta(ctx context.Context, agentMeta *api.AgentMeta) context.Context
• func NewTokenCredentials(token string, insecure bool) credentials.PerRPCCredentials
• func StreamAgentMetaInterceptor() ...
• func UnaryAgentMetaInterceptor() ...

Functions

func AgentMetaFromContext

func AgentMetaFromContext(ctx context.Context) *api.AgentMeta

func AgentMetaFromRawContext

func AgentMetaFromRawContext(ctx context.Context) (*api.AgentMeta, error)

func AgentTokenFromContext

func AgentTokenFromContext(ctx context.Context) api.AgentToken

AgentTokenFromContext extracts the agent token from the given context

func InjectAgentMeta

func InjectAgentMeta(ctx context.Context, agentMeta *api.AgentMeta) context.Context

func NewTokenCredentials

func NewTokenCredentials(token string, insecure bool) credentials.PerRPCCredentials

func StreamAgentMetaInterceptor

func StreamAgentMetaInterceptor() func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

StreamAgentMetaInterceptor is a gRPC server-side interceptor that populates context with api.AgentMeta for streaming RPCs.

func UnaryAgentMetaInterceptor

func UnaryAgentMetaInterceptor() func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryAgentMetaInterceptor is a gRPC server-side interceptor that populates context with api.AgentMeta for unary RPCs.