Documentation
¶
Index ¶
- type OrgTPStore
- type ResourceTPStore
- type TPStore
- func (s *TPStore) Flush(ctx context.Context, store OrgTPStore) error
- func (s *TPStore) FlushAll(ctx context.Context) error
- func (s *TPStore) ForOrg(ctx context.Context, id string) (OrgTPStore, error)
- func (s *TPStore) ForResource(ctx context.Context, id string, resource []*cp.KeyValue) (ResourceTPStore, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OrgTPStore ¶
type OrgTPStore interface {
DeleteTracepoints(ids ...string) error
AddTracepoint(tracepoint *tp.TracePointConfig) error
FindTracepoints(request *deepql.CommandRequest) ([]*tp.TracePointConfig, error)
LoadAll() ([]*tp.TracePointConfig, error)
// contains filtered or unexported methods
}
type ResourceTPStore ¶
type ResourceTPStore interface {
ProcessRequest(req *deeppb.LoadTracepointRequest) (*deeppb.LoadTracepointResponse, error)
AddTracepoint(tp *tp.TracePointConfig) error
DeleteTracepoints(ids ...string) error
}
type TPStore ¶
type TPStore struct {
// contains filtered or unexported fields
}
func (*TPStore) Flush ¶
func (s *TPStore) Flush(ctx context.Context, store OrgTPStore) error
Flush will sync the in memory changes to disk
func (*TPStore) ForOrg ¶
ForOrg will find or create a in memory store for the given org id this will load the org block from storage, if we do not already have a copy
func (*TPStore) ForResource ¶
func (s *TPStore) ForResource(ctx context.Context, id string, resource []*cp.KeyValue) (ResourceTPStore, error)
ForResource will find or create a new in memory store for the defined resource these stores are partitioned by org id
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.