nodebinding

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

type ICore interface {
	CreateNodeBinding(ctx context.Context, m *Model) error
	Exists(ctx context.Context, key string) (bool, error)
	DeleteNodeBinding(ctx context.Context, key string, m *Model) error
	ListKeys(ctx context.Context, prefix string) ([]string, error)
	List(ctx context.Context, prefix string) ([]*Model, error)
	TriggerNodeBindingRefresh(ctx context.Context) error
}

type IRepo interface {
	common.IRepo
	List(ctx context.Context, prefix string) ([]common.IModel, error)
}

type Model struct {
	common.BaseModel
	ID                  string `json:"id"`
	NodeID              string `json:"node_id"`
	SubscriptionID      string `json:"subscription_id"`
	SubscriptionVersion string `json:"subscription_version"`
	Partition           int    `json:"partition"`
}

type Repo struct {
	common.BaseRepo
}