slcontainer

Jan 13, 2025

Changes in this version

+ var ErrInvalidAuthID = fmt.Errorf("invalid auth id")

+ var ErrInvalidAuthType = fmt.Errorf("invalid auth type")

+ var ErrInvalidLoaderID = fmt.Errorf("invalid loader id")

+ var ErrRequestNotFound = fmt.Errorf("request not found")

+ type Auth struct

+ Container map[string]*auth.SetAuthor

+ DefaultAuthenticator string

+ func NewAuth() *Auth

+ func (a *Auth) Add(id string, auth auth.SetAuthor)

+ func (a *Auth) Remove(id string)

+ func (a *Auth) SetDefault(id string)

+ func (a Auth) AddFromProto(id string, pbAuth *pb.Auth) error

+ func (a Auth) Exists(id string) bool

+ func (a Auth) Find(id string) (auth.SetAuthor, bool)

+ func (a Auth) GetDefault() auth.SetAuthor

+ type AuthResourceRequest struct

+ AuthID string

+ IsDefault bool

+ type CommandMapData struct

+ LoaderID string

+ OutputRoot string

+ SlaveValues map[string]any

+ StrMap *sync.Map

+ ThreadOnlyStrMap *sync.Map

+ type Encryption struct

+ Enabled bool

+ EncryptID string

+ type Loader struct

+ LoaderBuilderMap map[string]*strings.Builder

+ LoaderMap map[string]string

+ func NewLoader() *Loader

+ func (l *Loader) Build(loaderID string)

+ func (l *Loader) GetLoader(loaderID string) (string, bool)

+ func (l *Loader) WriteString(loaderID, data string) error

+ type LoaderResourceRequest struct

+ LoaderID string

+ type ReceiveChanelRequestContainer struct

+ ReqChan chan *pb.ReceiveChanelConnectResponse

+ func NewReceiveChanelRequestContainer() *ReceiveChanelRequestContainer

+ func (r *ReceiveChanelRequestContainer) Cast(reqID string)

+ func (r *ReceiveChanelRequestContainer) SendAuthResourceRequests(ctx context.Context, connectionID string, mapper *RequestConnectionMapper, ...) <-chan struct{}

+ func (r *ReceiveChanelRequestContainer) SendLoaderResourceRequests(ctx context.Context, connectionID string, mapper *RequestConnectionMapper, ...) <-chan struct{}

+ func (r *ReceiveChanelRequestContainer) SendStore(ctx context.Context, connectionID string, mapper *RequestConnectionMapper, ...) (<-chan struct{}, error)

+ func (r *ReceiveChanelRequestContainer) SendStoreResourceRequests(ctx context.Context, connectionID string, mapper *RequestConnectionMapper, ...) (<-chan struct{}, error)

+ func (r *ReceiveChanelRequestContainer) SendTargetResourceRequests(ctx context.Context, connectionID string, mapper *RequestConnectionMapper, ...) <-chan struct{}

+ type RequestConnectionMapper struct

+ func NewRequestConnectionMapper() *RequestConnectionMapper

+ func (r *RequestConnectionMapper) DeleteRequest(reqID string)

+ func (r *RequestConnectionMapper) DeleteRequestConnection(connectionID string)

+ func (r *RequestConnectionMapper) GetConnectionID(reqID string) (string, bool)

+ func (r *RequestConnectionMapper) GetRequestID(connectionID string) ([]string, bool)

+ func (r *RequestConnectionMapper) RegisterRequestConnection(reqID, connectionID string)

+ type RequestTermCaster struct

+ func NewRequestTermCaster() *RequestTermCaster

+ func (r *RequestTermCaster) Cast(reqID string)

+ func (r *RequestTermCaster) RegisterRequest(reqID string) <-chan struct{}

+ type SlaveContainer struct

+ Auth *Auth

+ CommandMap *sync.Map

+ Loader *Loader

+ ReceiveChanelRequestContainer *ReceiveChanelRequestContainer

+ Store *Store

+ Target *Target

+ func NewSlaveContainer() *SlaveContainer

+ func (s *SlaveContainer) AddCommandMap(cmdID string, data CommandMapData)

+ func (s *SlaveContainer) DeleteCommandMap(cmdID string)

+ func (s *SlaveContainer) GetCommandMap(cmdID string) (CommandMapData, bool)

+ func (s *SlaveContainer) SetSlaveValues(cmdID string, slaveValues map[string]any) error

+ func (s *SlaveContainer) SetStrMap(cmdID string, strMap map[string]any) error

+ func (s *SlaveContainer) SetThreadOnlyStrMap(cmdID string, strMap map[string]any) error

+ type Store struct

+ func NewStore() *Store

+ func (s *Store) AddData(bucketID, storeKey string, data []byte) error

+ func (s *Store) ExistData(bucketID, storeKey string) bool

+ func (s *Store) GetData(bucketID, storeKey string) (any, bool)

+ func (s *Store) RemoveData(bucketID, storeKey string)

+ type StoreData struct

+ BucketID string

+ Data []byte

+ Encryption Encryption

+ StoreKey string

+ type StoreDataKey struct

+ BucketID string

+ StoreKey string

+ type StoreDataRequest struct

+ StoreData []StoreData

+ type StoreResourceRequest struct

+ Requests []StoreRespectiveRequest

+ type StoreRespectiveRequest struct

+ BucketID string

+ Encryption Encryption

+ StoreKey string

+ type Target struct

+ func NewTarget() *Target

+ func (t *Target) Add(id string, target target.Target)

+ func (t *Target) Remove(id string)

+ func (t Target) AddFromProto(id string, pbT *pb.Target) error

+ func (t Target) Exists(id string) bool

+ func (t Target) Find(id string) (target.Target, bool)

+ type TargetResourceRequest struct

+ TargetID string