modshared

Documentation

Index

• Constants
• Variables
• func ApiToErrReporter(api Api) errz.ErrReporter
• type AgentMeta
  • func (*AgentMeta) Descriptor() ([]byte, []int)
  • func (x *AgentMeta) GetCommitId() string
  • func (x *AgentMeta) GetPodName() string
  • func (x *AgentMeta) GetPodNamespace() string
  • func (x *AgentMeta) GetVersion() string
  • func (*AgentMeta) ProtoMessage()
  • func (x *AgentMeta) ProtoReflect() protoreflect.Message
  • func (x *AgentMeta) Reset()
  • func (x *AgentMeta) String() string
• type Api
• type Factory
• type ModuleStartStopPhase
• type RpcApi
• type RpcApiStub
  • func (a *RpcApiStub) Log() *zap.Logger
  • func (a *RpcApiStub) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error

Constants

const (
	NoAgentId int64 = 0
)

Variables

var File_internal_module_modshared_modshared_proto protoreflect.FileDescriptor

Functions

func ApiToErrReporter

func ApiToErrReporter(api Api) errz.ErrReporter

Types

type AgentMeta

type AgentMeta struct {
	Version      string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CommitId     string `protobuf:"bytes,2,opt,name=commit_id,proto3" json:"commit_id,omitempty"`
	PodNamespace string `protobuf:"bytes,3,opt,name=pod_namespace,proto3" json:"pod_namespace,omitempty"`
	PodName      string `protobuf:"bytes,4,opt,name=pod_name,proto3" json:"pod_name,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentMeta) Descriptor

func (*AgentMeta) Descriptor() ([]byte, []int)

Deprecated: Use AgentMeta.ProtoReflect.Descriptor instead.

func (*AgentMeta) GetCommitId

func (x *AgentMeta) GetCommitId() string

func (*AgentMeta) GetPodName

func (x *AgentMeta) GetPodName() string

func (*AgentMeta) GetPodNamespace

func (x *AgentMeta) GetPodNamespace() string

func (*AgentMeta) GetVersion

func (x *AgentMeta) GetVersion() string

func (*AgentMeta) ProtoMessage

func (*AgentMeta) ProtoMessage()

func (*AgentMeta) ProtoReflect

func (x *AgentMeta) ProtoReflect() protoreflect.Message

func (*AgentMeta) Reset

func (x *AgentMeta) Reset()

func (*AgentMeta) String

func (x *AgentMeta) String() string

type Api

type Api interface {
	// HandleProcessingError can be used to handle errors occurring while processing a request.
	// If err is a (or wraps a) errz.UserError, it might be handled specially.
	HandleProcessingError(ctx context.Context, log *zap.Logger, agentId int64, msg string, err error)
}

Api provides the API for the module to use.

type Factory

type Factory interface {
	// Name returns module's name.
	Name() string
	// StartStopPhase defines when to start and stop module during the program lifecycle.
	StartStopPhase() ModuleStartStopPhase
}

type ModuleStartStopPhase

type ModuleStartStopPhase byte

const (
	ModuleStartBeforeServers ModuleStartStopPhase
	ModuleStartAfterServers
)

type RpcApi

type RpcApi interface {
	// Log returns a logger to use in the context of the request being processed.
	Log() *zap.Logger
	// HandleProcessingError can be used to handle errors occurring while processing a request.
	// If err is a (or wraps a) errz.UserError, it might be handled specially.
	HandleProcessingError(log *zap.Logger, agentId int64, msg string, err error)
	// HandleIoError can be used to handle I/O error produced by gRPC Send(), Recv() methods or any other I/O error.
	// It returns an error, compatible with gRPC status package.
	HandleIoError(log *zap.Logger, msg string, err error) error
	// PollWithBackoff runs f every duration given by BackoffManager.
	//
	// PollWithBackoff should be used by the top-level polling, so that it can be gracefully interrupted
	// by the server when necessary. E.g. when stream is nearing it's max connection age or program needs to
	// be shut down.
	// If sliding is true, the period is computed after f runs. If it is false then
	// period includes the runtime for f.
	// It returns when:
	// - stream's context is cancelled or max connection age has been reached. nil is returned in this case.
	// - f returns Done. error from f is returned in this case.
	PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error
}

RpcApi provides the API for the module's gRPC handlers to use.

type RpcApiStub

type RpcApiStub struct {
	StreamCtx context.Context
	Logger    *zap.Logger
}

func (*RpcApiStub) Log

func (a *RpcApiStub) Log() *zap.Logger

func (*RpcApiStub) PollWithBackoff

func (a *RpcApiStub) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error