etcd

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 20, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	DataDir  string
	LogLevel string

	config.EtcdConfig
}

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 

func (r *StateRepository) ACLPolicies(ctx context.Context) ([]*structs.ACLPolicy, error)

ACLPolicies :

func (*StateRepository) ACLPolicyByName 

func (r *StateRepository) ACLPolicyByName(ctx context.Context, name string) (*structs.ACLPolicy, error)

ACLPolicyByName :

func (*StateRepository) ACLSetState 

func (r *StateRepository) ACLSetState(ctx context.Context, s *structs.ACLState) error

ACLSetState :

func (*StateRepository) ACLState 

func (r *StateRepository) ACLState(ctx context.Context) (*structs.ACLState, error)

ACLState :

func (*StateRepository) ACLTokenByID 

func (r *StateRepository) ACLTokenByID(ctx context.Context, id string) (*structs.ACLToken, error)

ACLTokenByID :

func (*StateRepository) ACLTokenBySecret 

func (r *StateRepository) ACLTokenBySecret(ctx context.Context, secret string) (*structs.ACLToken, error)

ACLTokenBySecret :

func (*StateRepository) ACLTokens 

func (r *StateRepository) ACLTokens(ctx context.Context) ([]*structs.ACLToken, error)

ACLTokens :

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 

func (r *StateRepository) InterfaceByID(ctx context.Context, id string) (*structs.Interface, error)

InterfaceByID :

func (*StateRepository) Interfaces 

func (r *StateRepository) Interfaces(ctx context.Context) ([]*structs.Interface, error)

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 

func (r *StateRepository) NetworkByID(ctx context.Context, id string) (*structs.Network, error)

NetworkByID :

func (*StateRepository) NetworkByName 

func (r *StateRepository) NetworkByName(ctx context.Context, s string) (*structs.Network, error)

NetworkByName :

func (*StateRepository) Networks 

func (r *StateRepository) Networks(ctx context.Context) ([]*structs.Network, error)

Networks :

func (*StateRepository) NodeByID 

func (r *StateRepository) NodeByID(ctx context.Context, id string) (*structs.Node, error)

NodeByID :

func (*StateRepository) NodeBySecretID 

func (r *StateRepository) NodeBySecretID(ctx context.Context, s string) (*structs.Node, error)

Nodes :

func (*StateRepository) Nodes 

func (r *StateRepository) Nodes(ctx context.Context) ([]*structs.Node, error)

Nodes :

func (*StateRepository) Transaction 

func (r *StateRepository) Transaction(ctx context.Context) state.Transaction

Transaction

func (*StateRepository) UpsertACLPolicy 

func (r *StateRepository) UpsertACLPolicy(ctx context.Context, p *structs.ACLPolicy) error

UpsertACLPolicy :

func (*StateRepository) UpsertACLToken 

func (r *StateRepository) UpsertACLToken(ctx context.Context, t *structs.ACLToken) error

UpsertACLToken :

func (*StateRepository) UpsertConnection 

func (r *StateRepository) UpsertConnection(ctx context.Context, n *structs.Connection) error

UpsertConnection :

func (*StateRepository) UpsertInterface 

func (r *StateRepository) UpsertInterface(ctx context.Context, n *structs.Interface) error

UpsertInterface :

func (*StateRepository) UpsertNetwork 

func (r *StateRepository) UpsertNetwork(ctx context.Context, n *structs.Network) error

UpsertNetwork :

func (*StateRepository) UpsertNode 

func (r *StateRepository) UpsertNode(ctx context.Context, n *structs.Node) error

UpsertNode :

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.