instance

Documentation

Index

• func NewSentryWriter(log *zap.Logger) sentryWriter
• type APIClusterInfoOutput
• type APIInstanceInfo
• type APIRoleRestartInput
• type APIRoleRestartOutput
• type ClusterInfo
• type Instance
  • func New() *Instance
  • func (i *Instance) APIClusterInfo() usecase.Interactor
  • func (i *Instance) APIClusterRoleRestart() usecase.Interactor
  • func (i *Instance) APIInstanceInfo() usecase.Interactor
  • func (i *Instance) DispatchEvent(topic string, ev *roles.Event)
  • func (i *Instance) ForRole(roleId string, ctx context.Context) *RoleInstance
  • func (i *Instance) Log() *zap.Logger
  • func (i *Instance) Role(id string) roles.Role
  • func (i *Instance) Start()
  • func (i *Instance) Stop()
• type InstanceInfo
• type RoleContext
• type RoleInstance
  • func (ri *RoleInstance) AddEventListener(topic string, handler roles.EventHandler)
  • func (ri *RoleInstance) Context() context.Context
  • func (ri *RoleInstance) DispatchEvent(topic string, ev *roles.Event)
  • func (ri *RoleInstance) ExecuteHook(options roles.HookOptions, args ...interface{})
  • func (ri *RoleInstance) HookEnvironment(options roles.HookOptions) map[string]interface{}
  • func (ri *RoleInstance) KV() *storage.Client
  • func (ri *RoleInstance) Log() *zap.Logger
  • func (ri *RoleInstance) Migrator() roles.RoleMigrator

Functions

func NewSentryWriter

func NewSentryWriter(log *zap.Logger) sentryWriter

Types

type APIClusterInfoOutput

type APIClusterInfoOutput struct {
	ClusterVersion      string         `json:"clusterVersion" required:"true"`
	ClusterVersionShort string         `json:"clusterVersionShort" required:"true"`
	Instances           []InstanceInfo `json:"instances" required:"true"`
}

type APIInstanceInfo

type APIInstanceInfo struct {
	Version   string `json:"version" required:"true"`
	BuildHash string `json:"buildHash" required:"true"`

	Dirs *extconfig.ExtConfigDirs `json:"dirs" required:"true"`

	InstanceIdentifier string `json:"instanceIdentifier" required:"true"`
	InstanceIP         string `json:"instanceIP" required:"true"`
}

type APIRoleRestartInput

type APIRoleRestartInput struct {
	ID string `json:"roleId"`
}

type APIRoleRestartOutput

type APIRoleRestartOutput struct{}

type ClusterInfo

type ClusterInfo struct {
	Setup bool `json:"setup"`
}

type Instance

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

func New

func New() *Instance

func (*Instance) APIClusterInfo

func (i *Instance) APIClusterInfo() usecase.Interactor

func (*Instance) APIClusterRoleRestart

func (i *Instance) APIClusterRoleRestart() usecase.Interactor

func (*Instance) APIInstanceInfo

func (i *Instance) APIInstanceInfo() usecase.Interactor

func (*Instance) DispatchEvent

func (i *Instance) DispatchEvent(topic string, ev *roles.Event)

func (*Instance) ForRole

func (i *Instance) ForRole(roleId string, ctx context.Context) *RoleInstance

func (*Instance) Log

func (i *Instance) Log() *zap.Logger

func (*Instance) Role

func (i *Instance) Role(id string) roles.Role

func (*Instance) Start

func (i *Instance) Start()

func (*Instance) Stop

func (i *Instance) Stop()

type InstanceInfo

type InstanceInfo struct {
	Version    string   `json:"version" required:"true"`
	Roles      []string `json:"roles" required:"true"`
	Identifier string   `json:"identifier" required:"true"`
	IP         string   `json:"ip" required:"true"`
}

type RoleContext

type RoleContext struct {
	Role              roles.Role
	RoleInstance      *RoleInstance
	ContextCancelFunc context.CancelFunc
}

type RoleInstance

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

func (*RoleInstance) AddEventListener

func (ri *RoleInstance) AddEventListener(topic string, handler roles.EventHandler)

func (*RoleInstance) Context

func (ri *RoleInstance) Context() context.Context

func (*RoleInstance) DispatchEvent

func (ri *RoleInstance) DispatchEvent(topic string, ev *roles.Event)

func (*RoleInstance) ExecuteHook

func (ri *RoleInstance) ExecuteHook(options roles.HookOptions, args ...interface{})

func (*RoleInstance) HookEnvironment

func (ri *RoleInstance) HookEnvironment(options roles.HookOptions) map[string]interface{}

func (*RoleInstance) KV

func (ri *RoleInstance) KV() *storage.Client

func (*RoleInstance) Log

func (ri *RoleInstance) Log() *zap.Logger

func (*RoleInstance) Migrator

func (ri *RoleInstance) Migrator() roles.RoleMigrator