Documentation ¶
Index ¶
- type Config
- type StateRepository
- func (r *StateRepository) ACLPolicies(ctx context.Context) ([]*structs.ACLPolicy, error)
- func (r *StateRepository) ACLPolicyByName(ctx context.Context, name string) (*structs.ACLPolicy, error)
- func (r *StateRepository) ACLSetState(ctx context.Context, s *structs.ACLState) error
- func (r *StateRepository) ACLState(ctx context.Context) (*structs.ACLState, error)
- func (r *StateRepository) ACLTokenByID(ctx context.Context, id string) (*structs.ACLToken, error)
- func (r *StateRepository) ACLTokenBySecret(ctx context.Context, secret string) (*structs.ACLToken, error)
- func (r *StateRepository) ACLTokens(ctx context.Context) ([]*structs.ACLToken, error)
- func (r *StateRepository) ConnectionByID(ctx context.Context, id string) (*structs.Connection, error)
- func (r *StateRepository) ConnectionByInterfaceIDs(ctx context.Context, a, b string) (*structs.Connection, error)
- func (r *StateRepository) Connections(ctx context.Context) ([]*structs.Connection, error)
- func (r *StateRepository) ConnectionsByInterfaceID(ctx context.Context, id string) ([]*structs.Connection, error)
- func (r *StateRepository) ConnectionsByNetworkID(ctx context.Context, id string) ([]*structs.Connection, error)
- func (r *StateRepository) ConnectionsByNodeID(ctx context.Context, id string) ([]*structs.Connection, error)
- func (r *StateRepository) DeleteACLPolicies(ctx context.Context, names []string) error
- func (r *StateRepository) DeleteACLTokens(ctx context.Context, ids []string) error
- func (r *StateRepository) DeleteConnections(ctx context.Context, ids []string) error
- func (r *StateRepository) DeleteInterfaces(ctx context.Context, ids []string) error
- func (r *StateRepository) DeleteNetworks(ctx context.Context, ids []string) error
- func (r *StateRepository) DeleteNodes(ctx context.Context, ids []string) error
- func (r *StateRepository) InterfaceByID(ctx context.Context, id string) (*structs.Interface, error)
- func (r *StateRepository) Interfaces(ctx context.Context) ([]*structs.Interface, error)
- func (r *StateRepository) InterfacesByNetworkID(ctx context.Context, id string) ([]*structs.Interface, error)
- func (r *StateRepository) InterfacesByNodeID(ctx context.Context, id string) ([]*structs.Interface, error)
- func (r *StateRepository) Name() string
- func (r *StateRepository) NetworkByID(ctx context.Context, id string) (*structs.Network, error)
- func (r *StateRepository) NetworkByName(ctx context.Context, s string) (*structs.Network, error)
- func (r *StateRepository) Networks(ctx context.Context) ([]*structs.Network, error)
- func (r *StateRepository) NodeByID(ctx context.Context, id string) (*structs.Node, error)
- func (r *StateRepository) NodeBySecretID(ctx context.Context, s string) (*structs.Node, error)
- func (r *StateRepository) Nodes(ctx context.Context) ([]*structs.Node, error)
- func (r *StateRepository) Transaction(ctx context.Context) state.Transaction
- func (r *StateRepository) UpsertACLPolicy(ctx context.Context, p *structs.ACLPolicy) error
- func (r *StateRepository) UpsertACLToken(ctx context.Context, t *structs.ACLToken) error
- func (r *StateRepository) UpsertConnection(ctx context.Context, n *structs.Connection) error
- func (r *StateRepository) UpsertInterface(ctx context.Context, n *structs.Interface) error
- func (r *StateRepository) UpsertNetwork(ctx context.Context, n *structs.Network) error
- func (r *StateRepository) UpsertNode(ctx context.Context, n *structs.Node) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StateRepository ¶
type StateRepository struct {
// contains filtered or unexported fields
}
StateRepository implements StateRepository
func NewStateRepository ¶
func NewStateRepository(config *Config) (*StateRepository, error)
NewStateRepository :
func (*StateRepository) ACLPolicies ¶
ACLPolicies :
func (*StateRepository) ACLPolicyByName ¶
func (r *StateRepository) ACLPolicyByName(ctx context.Context, name string) (*structs.ACLPolicy, error)
ACLPolicyByName :
func (*StateRepository) ACLSetState ¶
ACLSetState :
func (*StateRepository) ACLTokenByID ¶
ACLTokenByID :
func (*StateRepository) ACLTokenBySecret ¶
func (r *StateRepository) ACLTokenBySecret(ctx context.Context, secret string) (*structs.ACLToken, error)
ACLTokenBySecret :
func (*StateRepository) ConnectionByID ¶
func (r *StateRepository) ConnectionByID(ctx context.Context, id string) (*structs.Connection, error)
ConnectionByID :
func (*StateRepository) ConnectionByInterfaceIDs ¶
func (r *StateRepository) ConnectionByInterfaceIDs(ctx context.Context, a, b string) (*structs.Connection, error)
ConnectionByInterfaceIDs :
func (*StateRepository) Connections ¶
func (r *StateRepository) Connections(ctx context.Context) ([]*structs.Connection, error)
Connections :
func (*StateRepository) ConnectionsByInterfaceID ¶
func (r *StateRepository) ConnectionsByInterfaceID(ctx context.Context, id string) ([]*structs.Connection, error)
ConnectionsByInterfaceID :
func (*StateRepository) ConnectionsByNetworkID ¶
func (r *StateRepository) ConnectionsByNetworkID(ctx context.Context, id string) ([]*structs.Connection, error)
ConnectionsByNetworkID :
func (*StateRepository) ConnectionsByNodeID ¶
func (r *StateRepository) ConnectionsByNodeID(ctx context.Context, id string) ([]*structs.Connection, error)
ConnectionsByNodeID :
func (*StateRepository) DeleteACLPolicies ¶
func (r *StateRepository) DeleteACLPolicies(ctx context.Context, names []string) error
DeleteACLPolicies :
func (*StateRepository) DeleteACLTokens ¶
func (r *StateRepository) DeleteACLTokens(ctx context.Context, ids []string) error
DeleteACLTokens :
func (*StateRepository) DeleteConnections ¶
func (r *StateRepository) DeleteConnections(ctx context.Context, ids []string) error
DeleteConnections :
func (*StateRepository) DeleteInterfaces ¶
func (r *StateRepository) DeleteInterfaces(ctx context.Context, ids []string) error
DeleteInterfaces :
func (*StateRepository) DeleteNetworks ¶
func (r *StateRepository) DeleteNetworks(ctx context.Context, ids []string) error
DeleteNetworks :
func (*StateRepository) DeleteNodes ¶
func (r *StateRepository) DeleteNodes(ctx context.Context, ids []string) error
DeleteNodes :
func (*StateRepository) InterfaceByID ¶
InterfaceByID :
func (*StateRepository) Interfaces ¶
Interfaces :
func (*StateRepository) InterfacesByNetworkID ¶
func (r *StateRepository) InterfacesByNetworkID(ctx context.Context, id string) ([]*structs.Interface, error)
InterfacesByNetworkID :
func (*StateRepository) InterfacesByNodeID ¶
func (r *StateRepository) InterfacesByNodeID(ctx context.Context, id string) ([]*structs.Interface, error)
InterfacesByNodeID :
func (*StateRepository) Name ¶
func (r *StateRepository) Name() string
Name returns the name identifying the state repository.
func (*StateRepository) NetworkByID ¶
NetworkByID :
func (*StateRepository) NetworkByName ¶
NetworkByName :
func (*StateRepository) NodeBySecretID ¶
Nodes :
func (*StateRepository) Transaction ¶
func (r *StateRepository) Transaction(ctx context.Context) state.Transaction
Transaction
func (*StateRepository) UpsertACLPolicy ¶
UpsertACLPolicy :
func (*StateRepository) UpsertACLToken ¶
UpsertACLToken :
func (*StateRepository) UpsertConnection ¶
func (r *StateRepository) UpsertConnection(ctx context.Context, n *structs.Connection) error
UpsertConnection :
func (*StateRepository) UpsertInterface ¶
UpsertInterface :
func (*StateRepository) UpsertNetwork ¶
UpsertNetwork :
func (*StateRepository) UpsertNode ¶
UpsertNode :