framework

type Cluster interface {
	SetFrameworkID(id string)
	GetFrameworkID() string

	AddGroup(group *Group)
	GetGroup(id string) *Group
	ExistsGroup(id string) bool
	GetGroups() []*Group
}

type Consumer struct {
	ID string `json:"id"`
}

type ErrorResponse struct {
	Error string `json:"error"`
}

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

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

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

type GonsumerFrameworkConfig struct {
	Api              string
	Master           string
	FrameworkName    string
	FrameworkRole    string
	FrameworkStorage string
	FrameworkTimeout time.Duration
	User             string
	BindIP           string
}

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

type Group struct {
	ID               string   `json:"id"`
	Subscriptions    []string `json:"subscriptions"`
	BootstrapBrokers []string `json:"bootstrap_brokers"`

	Consumers []*Consumer `json:"consumers"`
}

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

type Reconciler struct {
	ReconcileDelay    time.Duration
	ReconcileMaxTries int
	// contains filtered or unexported fields
}

type Scheduler interface {
	Cluster() Cluster
}

type Server interface {
	Start() error
}

type Storage interface {
	Save([]byte) error
	Load() ([]byte, error)
}

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