managedstream

type FrameCache interface {
	// GetActiveChannels returns active managed stream channels with JSON schema.
	GetActiveChannels(orgID int64) (map[string]json.RawMessage, error)
	// GetFrame returns full JSON frame for a channel in org.
	GetFrame(ctx context.Context, orgID int64, channel string) (json.RawMessage, bool, error)
	// Update updates frame cache and returns true if schema changed.
	Update(ctx context.Context, orgID int64, channel string, frameJson data.FrameJSONCache) (bool, error)
}

type LocalPublisher interface {
	PublishLocal(channel string, data []byte) error
}

type ManagedChannel struct {
	Channel    string          `json:"channel"`
	MinuteRate int64           `json:"minute_rate"`
	Data       json.RawMessage `json:"data"`
}

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

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

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

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