ufwhandler

Documentation

Index

• func Cleanup(ctx *context.Context, client *client.Client)
• func CreateClient() (*context.Context, *client.Client, error)
• func CreateUfwRule(ch <-chan *types.ContainerJSON, c *cache.Cache)
• func DeleteUfwRule(containerID <-chan string, c *cache.Cache)
• func Reconnect() (*context.Context, *client.Client)
• func StreamEvents(ctx *context.Context, c *client.Client) (<-chan events.Message, <-chan error)
• func Sync(ctx *context.Context, createChannel chan *types.ContainerJSON, ...)
• type TrackedContainer
• type UfwRule

Functions

func Cleanup

func Cleanup(ctx *context.Context, client *client.Client)

func CreateClient

func CreateClient() (*context.Context, *client.Client, error)

func CreateUfwRule

func CreateUfwRule(ch <-chan *types.ContainerJSON, c *cache.Cache)

func DeleteUfwRule

func DeleteUfwRule(containerID <-chan string, c *cache.Cache)

func Reconnect

func Reconnect() (*context.Context, *client.Client)

func StreamEvents

func StreamEvents(ctx *context.Context, c *client.Client) (<-chan events.Message, <-chan error)

func Sync

func Sync(ctx *context.Context, createChannel chan *types.ContainerJSON, client *client.Client)

Types

type TrackedContainer

type TrackedContainer struct {
	Name             string
	IPAddress        string
	Labels           map[string]string
	UfwInboundRules  []UfwRule
	UfwOutboundRules []UfwRule
}

type UfwRule

type UfwRule struct {
	CIDR    string
	Port    string
	Proto   string
	Comment string
}