coordinator

Documentation

Index

• type Config
  • func (c *Config) Validate() error
• type Coordinator
  • func NewCoordinator(name string, coordinatorType Type, config *RawMessage, handlers *handler.Peer, ...) (Coordinator, error)
• type RawMessage
  • func (r *RawMessage) Unmarshal(v interface{}) error
  • func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Type

Types

type Config

type Config struct {
	Type Type `yaml:"type"`

	Config *RawMessage `yaml:"config"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Coordinator

type Coordinator interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Type() string
}

func NewCoordinator

func NewCoordinator(name string, coordinatorType Type, config *RawMessage, handlers *handler.Peer, captureDelay time.Duration, log logrus.FieldLogger) (Coordinator, error)

type RawMessage

type RawMessage struct {
	// contains filtered or unexported fields
}

func (*RawMessage) Unmarshal

func (r *RawMessage) Unmarshal(v interface{}) error

func (*RawMessage) UnmarshalYAML

func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error

type Type

type Type string

const (
	TypeUnknown Type = "unknown"
	TypeStatic  Type = static.Type
	TypeXatu    Type = xatuCoordinator.Type
)