Documentation
¶
Index ¶
- Constants
- func AddTrustedKey(request *grpc_config.TrustedKeyRequest, nonce []byte, ...) error
- func CreateJWT(claims jwt.Claims) (token string, e error)
- func DecryptString(cryptText string) (string, error)
- func EncryptString(plainText string) (string, error)
- func GetKeyManagerKey(name string) (ssh.PublicKey, error)
- func GetRsaPublicKey() (*rsa.PublicKey, error)
- func GetTrustedKeys() map[string]string
- func HandleRegisterKeyManagerCommand(commandMessage *axon_server.Command, ...) (*axon_utils.Error, error)
- func HandleRegisterTrustedKeyCommand(commandMessage *axon_server.Command, ...) (*axon_utils.Error, error)
- func ParsePrivateKey(pemString string) (givenPrivateKey *rsa.PrivateKey, e error)
- func SetPrivateKey(name string, pemString string) error
- func UnsafeSetKeyManager(publicKey *grpc_config.PublicKey)
- func UnsafeSetTrustedKey(publicKey *grpc_config.PublicKey)
- type KeyManagerAddedEvent
- type KeyManagerRemovedEvent
- type Projection
- type TrustedKeyAddedEvent
- type TrustedKeyRemovedEvent
Constants ¶
View Source
const AggregateIdentifier = "trusted-keys-aggregate"
Variables ¶
This section is empty.
Functions ¶
func AddTrustedKey ¶
func AddTrustedKey(request *grpc_config.TrustedKeyRequest, nonce []byte, clientConnection *axon_utils.ClientConnection) error
func DecryptString ¶
func EncryptString ¶
func GetRsaPublicKey ¶
func GetTrustedKeys ¶
func HandleRegisterKeyManagerCommand ¶
func HandleRegisterKeyManagerCommand(commandMessage *axon_server.Command, clientConnection *axon_utils.ClientConnection) (*axon_utils.Error, error)
func HandleRegisterTrustedKeyCommand ¶
func HandleRegisterTrustedKeyCommand(commandMessage *axon_server.Command, clientConnection *axon_utils.ClientConnection) (*axon_utils.Error, error)
func ParsePrivateKey ¶
func ParsePrivateKey(pemString string) (givenPrivateKey *rsa.PrivateKey, e error)
func SetPrivateKey ¶
func UnsafeSetKeyManager ¶
func UnsafeSetKeyManager(publicKey *grpc_config.PublicKey)
func UnsafeSetTrustedKey ¶
func UnsafeSetTrustedKey(publicKey *grpc_config.PublicKey)
Types ¶
type KeyManagerAddedEvent ¶
type KeyManagerAddedEvent struct {
grpc_config.KeyManagerAddedEvent
}
func (*KeyManagerAddedEvent) ApplyTo ¶
func (event *KeyManagerAddedEvent) ApplyTo(projectionWrapper interface{})
type KeyManagerRemovedEvent ¶
type KeyManagerRemovedEvent struct {
grpc_config.KeyManagerRemovedEvent
}
func (*KeyManagerRemovedEvent) ApplyTo ¶
func (event *KeyManagerRemovedEvent) ApplyTo(projectionWrapper interface{})
type Projection ¶
type Projection struct {
TrustedKeys map[string]string
KeyManagers map[string]string
AggregateState axon_utils.AggregateState
}
func RestoreProjection ¶
func RestoreProjection(aggregateIdentifier string, clientConnection *axon_utils.ClientConnection) *Projection
func (*Projection) Apply ¶
func (projection *Projection) Apply(event axon_utils.Event)
func (*Projection) GetAggregateState ¶
func (projection *Projection) GetAggregateState() axon_utils.AggregateState
type TrustedKeyAddedEvent ¶
type TrustedKeyAddedEvent struct {
grpc_config.TrustedKeyAddedEvent
}
Redeclare event types, so that they can be extended with event handler methods.
func (*TrustedKeyAddedEvent) ApplyTo ¶
func (event *TrustedKeyAddedEvent) ApplyTo(projectionWrapper interface{})
type TrustedKeyRemovedEvent ¶
type TrustedKeyRemovedEvent struct {
grpc_config.TrustedKeyRemovedEvent
}
func (*TrustedKeyRemovedEvent) ApplyTo ¶
func (event *TrustedKeyRemovedEvent) ApplyTo(projectionWrapper interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.