var (
MetricLatency = promauto.NewHistogramVec(prometheus.HistogramOpts{
Name: "rekor_api_latency",
Help: "Api Latency on calls",
}, []string{"path", "code"})
MetricLatencySummary = promauto.NewSummaryVec(prometheus.SummaryOpts{
Name: "rekor_api_latency_summary",
Help: "Api Latency on calls",
}, []string{"path", "code"})
MetricRequestLatency = promauto.NewHistogramVec(prometheus.HistogramOpts{
Name: "rekor_latency_by_api",
Help: "Api Latency (in ns) by path and method",
Buckets: prometheus.ExponentialBucketsRange(
float64(time.Millisecond),
float64(4*time.Second),
10),
}, []string{"path", "method"})
MetricRequestCount = promauto.NewCounterVec(prometheus.CounterOpts{
Name: "rekor_qps_by_api",
Help: "Api QPS by path, method, and response code",
}, []string{"path", "method", "code"})
CheckpointPublishCount = promauto.NewCounterVec(prometheus.CounterOpts{
Name: "rekor_checkpoint_publish",
Help: "Checkpoint publishing by shard and code",
}, []string{"shard", "code"})
)
var ErrNotFound = errors.New("grpc returned 0 leaves with success code")
func ConfigureAPI(treeID uint)
func CreateLogEntryHandler(params entries.CreateLogEntryParams) middleware.Responder
CreateLogEntryHandler creates new entry into log
func CreateLogEntryNotImplementedHandler(_ entries.CreateLogEntryParams) middleware.Responder
func GetLogEntryByIndexHandler(params entries.GetLogEntryByIndexParams) middleware.Responder
GetLogEntryAndProofByIndexHandler returns the entry and inclusion proof for a specified log index
func GetLogEntryByIndexNotImplementedHandler(_ entries.GetLogEntryByIndexParams) middleware.Responder
func GetLogEntryByUUIDHandler(params entries.GetLogEntryByUUIDParams) middleware.Responder
GetLogEntryByUUIDHandler gets log entry and inclusion proof for specified UUID aka merkle leaf hash
func GetLogEntryByUUIDNotImplementedHandler(_ entries.GetLogEntryByUUIDParams) middleware.Responder
func GetLogInfoHandler(params tlog.GetLogInfoParams) middleware.Responder
GetLogInfoHandler returns the current size of the tree and the STH
func GetLogInfoNotImplementedHandler(_ tlog.GetLogInfoParams) middleware.Responder
func GetLogProofHandler(params tlog.GetLogProofParams) middleware.Responder
GetLogProofHandler returns information required to compute a consistency proof between two snapshots of log
func GetLogProofNotImplementedHandler(_ tlog.GetLogProofParams) middleware.Responder
func GetPublicKeyHandler(params pubkey.GetPublicKeyParams) middleware.Responder
func GetPublicKeyNotImplementedHandler(_ pubkey.GetPublicKeyParams) middleware.Responder
func NewRedisClient() *redis.Client
func SearchIndexHandler(params index.SearchIndexParams) middleware.Responder
func SearchIndexNotImplementedHandler(_ index.SearchIndexParams) middleware.Responder
func SearchLogQueryHandler(params entries.SearchLogQueryParams) middleware.Responder
SearchLogQueryHandler searches log by index, UUID, or proposed entry and returns array of entries found with inclusion proofs
func SearchLogQueryNotImplementedHandler(_ entries.SearchLogQueryParams) middleware.Responder
func StopAPI()
type API struct {
// contains filtered or unexported fields
}
func NewAPI(treeID uint) (*API, error)
Collection is a collection of sets.
its resulting values is a union or intersection of all the sets, depending on the operator.
type Collection struct {
// contains filtered or unexported fields
}
func NewCollection(operator string) *Collection
NewCollection creates a new collection.
func (u *Collection) Add(elements []string)
Add adds the elements into a new subset in the collection.
func (u *Collection) Values() []string
Values flattens the subsets using the operator, and returns the collection as a slice of strings.
Uniq is a collection of unique elements.
type Uniq map[string]struct{}
func NewUniq() Uniq
func (u Uniq) Add(elements ...string)
func (u Uniq) Intersect(other Uniq) Uniq
Intersect returns the intersection of two collections.
func (u Uniq) Union(other Uniq) Uniq
Union returns the union of two collections.
func (u Uniq) Values() []string