change

Documentation

Index

• Constants
• type Author
• type AuthorType
• type Context
  • func FromContext(ctx context.Context) *Context
  • func FromProtoBuf(ctx *cmd_pb.ChangeContext) *Context
  • func New() *Context
  • func (self *Context) AddToContext(ctx context.Context) context.Context
  • func (self *Context) GetAuthor() *Author
  • func (self *Context) GetContext() context.Context
  • func (self *Context) GetSource() *Source
  • func (self *Context) NewMutateContext() boltz.MutateContext
  • func (self *Context) PopulateMetadata(meta map[string]any)
  • func (self *Context) SetChangeAuthorId(val string) *Context
  • func (self *Context) SetChangeAuthorName(val string) *Context
  • func (self *Context) SetChangeAuthorType(val AuthorType) *Context
  • func (self *Context) SetSourceAuth(val string) *Context
  • func (self *Context) SetSourceLocal(val string) *Context
  • func (self *Context) SetSourceMethod(val string) *Context
  • func (self *Context) SetSourceRemote(val string) *Context
  • func (self *Context) SetSourceType(val string) *Context
  • func (self *Context) SetTraceId(val string) *Context
  • func (self *Context) ToProtoBuf() *cmd_pb.ChangeContext
• type ContextKeyType
• type Source

Constants

const (
	ContextKey ContextKeyType = "changeContext"

	AuthorIdKey   = "authorId"
	AuthorNameKey = "authorName"
	AuthorTypeKey = "authorType"
	TraceIdKey    = "traceId"
	SourceType    = "src.type"
	SourceAuth    = "src.auth"
	SourceMethod  = "src.method"
	SourceLocal   = "src.local"
	SourceRemote  = "src.remote"
)

const (
	AuthorTypeCert         = "cert"
	AuthorTypeIdentity     = "identity"
	AuthorTypeRouter       = "router"
	AuthorTypeController   = "controller"
	AuthorTypeUnattributed = "unattributed"
)

const (
	SourceTypeControlChannel = "ctrl.channel"
	SourceTypeRest           = "rest"
	SourceTypeWebSocket      = "websocket"
	SourceTypeXt             = "xt"
)

Types

type Author

type Author struct {
	Type string `json:"type"`
	Id   string `json:"id,omitempty"`
	Name string `json:"name,omitempty"`
}

type AuthorType

type AuthorType string

type Context

type Context struct {
	Attributes map[string]string
	RaftIndex  uint64
}

func FromContext

func FromContext(ctx context.Context) *Context

func FromProtoBuf

func FromProtoBuf(ctx *cmd_pb.ChangeContext) *Context

func New

func New() *Context

func (*Context) AddToContext

func (self *Context) AddToContext(ctx context.Context) context.Context

func (*Context) GetAuthor

func (self *Context) GetAuthor() *Author

func (*Context) GetContext

func (self *Context) GetContext() context.Context

func (*Context) GetSource

func (self *Context) GetSource() *Source

func (*Context) NewMutateContext

func (self *Context) NewMutateContext() boltz.MutateContext

func (*Context) PopulateMetadata

func (self *Context) PopulateMetadata(meta map[string]any)

func (*Context) SetChangeAuthorId

func (self *Context) SetChangeAuthorId(val string) *Context

func (*Context) SetChangeAuthorName

func (self *Context) SetChangeAuthorName(val string) *Context

func (*Context) SetChangeAuthorType

func (self *Context) SetChangeAuthorType(val AuthorType) *Context

func (*Context) SetSourceAuth

func (self *Context) SetSourceAuth(val string) *Context

func (*Context) SetSourceLocal

func (self *Context) SetSourceLocal(val string) *Context

func (*Context) SetSourceMethod

func (self *Context) SetSourceMethod(val string) *Context

func (*Context) SetSourceRemote

func (self *Context) SetSourceRemote(val string) *Context

func (*Context) SetSourceType

func (self *Context) SetSourceType(val string) *Context

func (*Context) SetTraceId

func (self *Context) SetTraceId(val string) *Context

func (*Context) ToProtoBuf

func (self *Context) ToProtoBuf() *cmd_pb.ChangeContext

type ContextKeyType

type ContextKeyType string

type Source

type Source struct {
	Type       string `json:"type"`
	Auth       string `json:"auth,omitempty"`
	LocalAddr  string `json:"localAddr,omitempty"`
	RemoteAddr string `json:"remoteAddr,omitempty"`
	Method     string `json:"method,omitempty"`
}