Documentation
¶
Index ¶
- Constants
- Variables
- func AssetFields(r Resource) map[string]string
- func CheckConfigFields(r Resource) map[string]string
- func ClusterRoleBindingFields(r Resource) map[string]string
- func ClusterRoleFields(r Resource) map[string]string
- func ContextNamespace(ctx context.Context) string
- func EntityFields(r Resource) map[string]string
- func EnvVarsToMap(vars []string) map[string]string
- func EventFields(r Resource) map[string]string
- func EventFilterFields(r Resource) map[string]string
- func EventsByLastOk(es []*Event) sort.Interface
- func EventsBySeverity(es []*Event) sort.Interface
- func EventsByTimestamp(es []*Event, asc bool) sort.Interface
- func ExtensionFields(r Resource) map[string]string
- func GetEntitySubscription(entityName string) string
- func HandlerFields(r Resource) map[string]string
- func HookConfigFields(r Resource) map[string]string
- func LoadCACerts(path string) (*x509.CertPool, error)
- func MutatorFields(r Resource) map[string]string
- func NamespaceFields(r Resource) map[string]string
- func PageContinueFromContext(ctx context.Context) string
- func PageSizeFromContext(ctx context.Context) int
- func RoleBindingFields(r Resource) map[string]string
- func RoleFields(r Resource) map[string]string
- func SetContextFromResource(ctx context.Context, r MultitenantResource) context.Context
- func SilencedFields(r Resource) map[string]string
- func SilencedName(subscription, check string) (string, error)
- func SortCheckConfigsByName(es []*CheckConfig, asc bool) sort.Interface
- func SortCheckConfigsByPredicate(cs []*CheckConfig, fn cmpCheckConfig) sort.Interface
- func SortEntitiesByID(es []*Entity, asc bool) sort.Interface
- func SortEntitiesByLastSeen(es []*Entity) sort.Interface
- func SortEntitiesByPredicate(es []*Entity, fn func(a, b *Entity) bool) sort.Interface
- func SortHandlersByName(hs []*Handler, asc bool) sort.Interface
- func SortHandlersByPredicate(hs []*Handler, fn cmpHandler) sort.Interface
- func SortSilencedByBegin(es []*Silenced) sort.Interface
- func SortSilencedByName(es []*Silenced) sort.Interface
- func SortSilencedByPredicate(es []*Silenced, fn func(a, b *Silenced) bool) sort.Interface
- func StandardClaims(subject string) jwt.StandardClaims
- func UserFields(r Resource) map[string]string
- func ValidateAssetName(name string) error
- func ValidateEnvVars(vars []string) error
- func ValidateInterval(freq uint32) error
- func ValidateName(name string) error
- func ValidateNameStrict(name string) error
- func ValidateOutputMetricFormat(format string) error
- func ValidateSubscriptionName(name string) error
- type AdhocRequest
- func (*AdhocRequest) Descriptor() ([]byte, []int)
- func (this *AdhocRequest) Equal(that interface{}) bool
- func (m *AdhocRequest) GetCreator() string
- func (m *AdhocRequest) GetReason() string
- func (m *AdhocRequest) GetSubscriptions() []string
- func (m *AdhocRequest) Marshal() (dAtA []byte, err error)
- func (m *AdhocRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdhocRequest) ProtoMessage()
- func (m *AdhocRequest) Reset()
- func (a *AdhocRequest) SetNamespace(namespace string)
- func (m *AdhocRequest) Size() (n int)
- func (a *AdhocRequest) StorePrefix() string
- func (m *AdhocRequest) String() string
- func (a *AdhocRequest) URIPath() string
- func (m *AdhocRequest) Unmarshal(dAtA []byte) error
- func (a *AdhocRequest) Validate() error
- func (m *AdhocRequest) XXX_DiscardUnknown()
- func (m *AdhocRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AdhocRequest) XXX_Merge(src proto.Message)
- func (m *AdhocRequest) XXX_Size() int
- func (m *AdhocRequest) XXX_Unmarshal(b []byte) error
- type AgentHandshake
- type Any
- func (*Any) Descriptor() ([]byte, []int)
- func (this *Any) Equal(that interface{}) bool
- func (m *Any) GetTypeUrl() string
- func (m *Any) GetValue() []byte
- func (m *Any) Marshal() (dAtA []byte, err error)
- func (m *Any) MarshalTo(dAtA []byte) (int, error)
- func (*Any) ProtoMessage()
- func (m *Any) Reset()
- func (m *Any) Size() (n int)
- func (m *Any) String() string
- func (m *Any) Unmarshal(dAtA []byte) error
- func (m *Any) XXX_DiscardUnknown()
- func (m *Any) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Any) XXX_Merge(src proto.Message)
- func (m *Any) XXX_Size() int
- func (m *Any) XXX_Unmarshal(b []byte) error
- type Asset
- func (*Asset) Descriptor() ([]byte, []int)
- func (this *Asset) Equal(that interface{}) bool
- func (a *Asset) Filename() string
- func (this *Asset) GetFilters() []string
- func (this *Asset) GetObjectMeta() ObjectMeta
- func (this *Asset) GetSha512() string
- func (this *Asset) GetURL() string
- func (m *Asset) Marshal() (dAtA []byte, err error)
- func (m *Asset) MarshalTo(dAtA []byte) (int, error)
- func (this *Asset) Proto() github_com_golang_protobuf_proto.Message
- func (*Asset) ProtoMessage()
- func (m *Asset) Reset()
- func (a *Asset) SetNamespace(namespace string)
- func (m *Asset) Size() (n int)
- func (a *Asset) StorePrefix() string
- func (m *Asset) String() string
- func (this *Asset) TestProto() github_com_golang_protobuf_proto.Message
- func (a *Asset) URIPath() string
- func (m *Asset) Unmarshal(dAtA []byte) error
- func (a *Asset) Validate() error
- func (m *Asset) XXX_DiscardUnknown()
- func (m *Asset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Asset) XXX_Merge(src proto.Message)
- func (m *Asset) XXX_Size() int
- func (m *Asset) XXX_Unmarshal(b []byte) error
- type AssetFace
- type AuthProvider
- type AuthProviderClaims
- type BackendHandshake
- type ByExecuted
- type Check
- func (*Check) Descriptor() ([]byte, []int)
- func (this *Check) Equal(that interface{}) bool
- func (this *Check) GetCheckHooks() []HookList
- func (this *Check) GetCommand() string
- func (this *Check) GetCron() string
- func (this *Check) GetDiscardOutput() bool
- func (this *Check) GetDuration() float64
- func (this *Check) GetEnvVars() []string
- func (this *Check) GetExecuted() int64
- func (this *Check) GetExtendedAttributes() []byte
- func (this *Check) GetHandlers() []string
- func (this *Check) GetHighFlapThreshold() uint32
- func (this *Check) GetHistory() []CheckHistory
- func (this *Check) GetHooks() []*Hook
- func (this *Check) GetInterval() uint32
- func (this *Check) GetIssued() int64
- func (this *Check) GetLastOK() int64
- func (this *Check) GetLowFlapThreshold() uint32
- func (this *Check) GetMaxOutputSize() int64
- func (this *Check) GetObjectMeta() ObjectMeta
- func (this *Check) GetOccurrences() int64
- func (this *Check) GetOccurrencesWatermark() int64
- func (this *Check) GetOutput() string
- func (this *Check) GetOutputMetricFormat() string
- func (this *Check) GetOutputMetricHandlers() []string
- func (this *Check) GetProxyEntityName() string
- func (this *Check) GetProxyRequests() *ProxyRequests
- func (this *Check) GetPublish() bool
- func (this *Check) GetRoundRobin() bool
- func (this *Check) GetRuntimeAssets() []string
- func (this *Check) GetSilenced() []string
- func (this *Check) GetState() string
- func (this *Check) GetStatus() uint32
- func (this *Check) GetStdin() bool
- func (this *Check) GetSubdue() *TimeWindowWhen
- func (this *Check) GetSubscriptions() []string
- func (this *Check) GetTimeout() uint32
- func (this *Check) GetTotalStateChange() uint32
- func (this *Check) GetTtl() int64
- func (m *Check) Marshal() (dAtA []byte, err error)
- func (c *Check) MarshalJSON() ([]byte, error)
- func (m *Check) MarshalTo(dAtA []byte) (int, error)
- func (c *Check) MergeWith(prevCheck *Check)
- func (this *Check) Proto() github_com_golang_protobuf_proto.Message
- func (*Check) ProtoMessage()
- func (m *Check) Reset()
- func (c *Check) SetNamespace(namespace string)
- func (m *Check) Size() (n int)
- func (c *Check) StorePrefix() string
- func (m *Check) String() string
- func (this *Check) TestProto() github_com_golang_protobuf_proto.Message
- func (c *Check) URIPath() string
- func (m *Check) Unmarshal(dAtA []byte) error
- func (c *Check) Validate() error
- func (m *Check) XXX_DiscardUnknown()
- func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Check) XXX_Merge(src proto.Message)
- func (m *Check) XXX_Size() int
- func (m *Check) XXX_Unmarshal(b []byte) error
- type CheckConfig
- func (*CheckConfig) Descriptor() ([]byte, []int)
- func (this *CheckConfig) Equal(that interface{}) bool
- func (this *CheckConfig) GetCheckHooks() []HookList
- func (this *CheckConfig) GetCommand() string
- func (this *CheckConfig) GetCron() string
- func (this *CheckConfig) GetDiscardOutput() bool
- func (this *CheckConfig) GetEnvVars() []string
- func (this *CheckConfig) GetExtendedAttributes() []byte
- func (this *CheckConfig) GetHandlers() []string
- func (this *CheckConfig) GetHighFlapThreshold() uint32
- func (this *CheckConfig) GetInterval() uint32
- func (this *CheckConfig) GetLowFlapThreshold() uint32
- func (this *CheckConfig) GetMaxOutputSize() int64
- func (this *CheckConfig) GetObjectMeta() ObjectMeta
- func (this *CheckConfig) GetOutputMetricFormat() string
- func (this *CheckConfig) GetOutputMetricHandlers() []string
- func (this *CheckConfig) GetProxyEntityName() string
- func (this *CheckConfig) GetProxyRequests() *ProxyRequests
- func (this *CheckConfig) GetPublish() bool
- func (this *CheckConfig) GetRoundRobin() bool
- func (this *CheckConfig) GetRuntimeAssets() []string
- func (this *CheckConfig) GetStdin() bool
- func (this *CheckConfig) GetSubdue() *TimeWindowWhen
- func (this *CheckConfig) GetSubscriptions() []string
- func (this *CheckConfig) GetTimeout() uint32
- func (this *CheckConfig) GetTtl() int64
- func (c *CheckConfig) IsSubdued() bool
- func (m *CheckConfig) Marshal() (dAtA []byte, err error)
- func (c *CheckConfig) MarshalJSON() ([]byte, error)
- func (m *CheckConfig) MarshalTo(dAtA []byte) (int, error)
- func (this *CheckConfig) Proto() github_com_golang_protobuf_proto.Message
- func (*CheckConfig) ProtoMessage()
- func (m *CheckConfig) Reset()
- func (c *CheckConfig) SetNamespace(namespace string)
- func (m *CheckConfig) Size() (n int)
- func (c *CheckConfig) StorePrefix() string
- func (m *CheckConfig) String() string
- func (this *CheckConfig) TestProto() github_com_golang_protobuf_proto.Message
- func (c *CheckConfig) URIPath() string
- func (m *CheckConfig) Unmarshal(dAtA []byte) error
- func (c *CheckConfig) Validate() error
- func (m *CheckConfig) XXX_DiscardUnknown()
- func (m *CheckConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CheckConfig) XXX_Merge(src proto.Message)
- func (m *CheckConfig) XXX_Size() int
- func (m *CheckConfig) XXX_Unmarshal(b []byte) error
- type CheckConfigFace
- type CheckFace
- type CheckHistory
- func (*CheckHistory) Descriptor() ([]byte, []int)
- func (this *CheckHistory) Equal(that interface{}) bool
- func (m *CheckHistory) GetExecuted() int64
- func (m *CheckHistory) GetStatus() uint32
- func (m *CheckHistory) Marshal() (dAtA []byte, err error)
- func (m *CheckHistory) MarshalTo(dAtA []byte) (int, error)
- func (*CheckHistory) ProtoMessage()
- func (m *CheckHistory) Reset()
- func (m *CheckHistory) Size() (n int)
- func (m *CheckHistory) String() string
- func (m *CheckHistory) Unmarshal(dAtA []byte) error
- func (m *CheckHistory) XXX_DiscardUnknown()
- func (m *CheckHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CheckHistory) XXX_Merge(src proto.Message)
- func (m *CheckHistory) XXX_Size() int
- func (m *CheckHistory) XXX_Unmarshal(b []byte) error
- type CheckRequest
- func (*CheckRequest) Descriptor() ([]byte, []int)
- func (this *CheckRequest) Equal(that interface{}) bool
- func (m *CheckRequest) GetAssets() []Asset
- func (m *CheckRequest) GetConfig() *CheckConfig
- func (m *CheckRequest) GetHooks() []HookConfig
- func (m *CheckRequest) GetIssued() int64
- func (m *CheckRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CheckRequest) ProtoMessage()
- func (m *CheckRequest) Reset()
- func (m *CheckRequest) Size() (n int)
- func (m *CheckRequest) String() string
- func (m *CheckRequest) Unmarshal(dAtA []byte) error
- func (m *CheckRequest) XXX_DiscardUnknown()
- func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CheckRequest) XXX_Merge(src proto.Message)
- func (m *CheckRequest) XXX_Size() int
- func (m *CheckRequest) XXX_Unmarshal(b []byte) error
- type Claims
- type ClusterHealth
- type ClusterRole
- func (*ClusterRole) Descriptor() ([]byte, []int)
- func (this *ClusterRole) Equal(that interface{}) bool
- func (this *ClusterRole) GetObjectMeta() ObjectMeta
- func (this *ClusterRole) GetRules() []Rule
- func (m *ClusterRole) Marshal() (dAtA []byte, err error)
- func (m *ClusterRole) MarshalTo(dAtA []byte) (int, error)
- func (this *ClusterRole) Proto() github_com_golang_protobuf_proto.Message
- func (*ClusterRole) ProtoMessage()
- func (m *ClusterRole) Reset()
- func (r *ClusterRole) SetNamespace(namespace string)
- func (m *ClusterRole) Size() (n int)
- func (r *ClusterRole) StorePrefix() string
- func (m *ClusterRole) String() string
- func (this *ClusterRole) TestProto() github_com_golang_protobuf_proto.Message
- func (r *ClusterRole) URIPath() string
- func (m *ClusterRole) Unmarshal(dAtA []byte) error
- func (r *ClusterRole) Validate() error
- func (m *ClusterRole) XXX_DiscardUnknown()
- func (m *ClusterRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterRole) XXX_Merge(src proto.Message)
- func (m *ClusterRole) XXX_Size() int
- func (m *ClusterRole) XXX_Unmarshal(b []byte) error
- type ClusterRoleBinding
- func (*ClusterRoleBinding) Descriptor() ([]byte, []int)
- func (this *ClusterRoleBinding) Equal(that interface{}) bool
- func (this *ClusterRoleBinding) GetObjectMeta() ObjectMeta
- func (this *ClusterRoleBinding) GetRoleRef() RoleRef
- func (this *ClusterRoleBinding) GetSubjects() []Subject
- func (m *ClusterRoleBinding) Marshal() (dAtA []byte, err error)
- func (m *ClusterRoleBinding) MarshalTo(dAtA []byte) (int, error)
- func (this *ClusterRoleBinding) Proto() github_com_golang_protobuf_proto.Message
- func (*ClusterRoleBinding) ProtoMessage()
- func (m *ClusterRoleBinding) Reset()
- func (b *ClusterRoleBinding) SetNamespace(namespace string)
- func (m *ClusterRoleBinding) Size() (n int)
- func (b *ClusterRoleBinding) StorePrefix() string
- func (m *ClusterRoleBinding) String() string
- func (this *ClusterRoleBinding) TestProto() github_com_golang_protobuf_proto.Message
- func (b *ClusterRoleBinding) URIPath() string
- func (m *ClusterRoleBinding) Unmarshal(dAtA []byte) error
- func (b *ClusterRoleBinding) Validate() error
- func (m *ClusterRoleBinding) XXX_DiscardUnknown()
- func (m *ClusterRoleBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterRoleBinding) XXX_Merge(src proto.Message)
- func (m *ClusterRoleBinding) XXX_Size() int
- func (m *ClusterRoleBinding) XXX_Unmarshal(b []byte) error
- type ClusterRoleBindingFace
- type ClusterRoleFace
- type ConstrainedResource
- type Deregistration
- func (*Deregistration) Descriptor() ([]byte, []int)
- func (this *Deregistration) Equal(that interface{}) bool
- func (m *Deregistration) GetHandler() string
- func (m *Deregistration) Marshal() (dAtA []byte, err error)
- func (m *Deregistration) MarshalTo(dAtA []byte) (int, error)
- func (*Deregistration) ProtoMessage()
- func (m *Deregistration) Reset()
- func (m *Deregistration) Size() (n int)
- func (m *Deregistration) String() string
- func (m *Deregistration) Unmarshal(dAtA []byte) error
- func (m *Deregistration) XXX_DiscardUnknown()
- func (m *Deregistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Deregistration) XXX_Merge(src proto.Message)
- func (m *Deregistration) XXX_Size() int
- func (m *Deregistration) XXX_Unmarshal(b []byte) error
- type Entity
- func (*Entity) Descriptor() ([]byte, []int)
- func (this *Entity) Equal(that interface{}) bool
- func (this *Entity) GetDeregister() bool
- func (this *Entity) GetDeregistration() Deregistration
- func (this *Entity) GetEntityClass() string
- func (this *Entity) GetExtendedAttributes() []byte
- func (this *Entity) GetLastSeen() int64
- func (this *Entity) GetObjectMeta() ObjectMeta
- func (this *Entity) GetRedact() []string
- func (e *Entity) GetRedactedEntity() *Entity
- func (this *Entity) GetSubscriptions() []string
- func (this *Entity) GetSystem() System
- func (this *Entity) GetUser() string
- func (m *Entity) Marshal() (dAtA []byte, err error)
- func (e *Entity) MarshalJSON() ([]byte, error)
- func (m *Entity) MarshalTo(dAtA []byte) (int, error)
- func (this *Entity) Proto() github_com_golang_protobuf_proto.Message
- func (*Entity) ProtoMessage()
- func (m *Entity) Reset()
- func (e *Entity) SetNamespace(namespace string)
- func (m *Entity) Size() (n int)
- func (e *Entity) StorePrefix() string
- func (m *Entity) String() string
- func (this *Entity) TestProto() github_com_golang_protobuf_proto.Message
- func (e *Entity) URIPath() string
- func (m *Entity) Unmarshal(dAtA []byte) error
- func (e *Entity) Validate() error
- func (m *Entity) XXX_DiscardUnknown()
- func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Entity) XXX_Merge(src proto.Message)
- func (m *Entity) XXX_Size() int
- func (m *Entity) XXX_Unmarshal(b []byte) error
- type EntityFace
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (this *Event) Equal(that interface{}) bool
- func (this *Event) GetCheck() *Check
- func (this *Event) GetEntity() *Entity
- func (this *Event) GetMetrics() *Metrics
- func (this *Event) GetObjectMeta() ObjectMeta
- func (this *Event) GetTimestamp() int64
- func (e *Event) HasCheck() bool
- func (e *Event) HasMetrics() bool
- func (e *Event) IsIncident() bool
- func (e *Event) IsResolution() bool
- func (e *Event) IsSilenced() bool
- func (e *Event) IsSilencedBy(entry *Silenced) bool
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (this *Event) Proto() github_com_golang_protobuf_proto.Message
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (e *Event) SetNamespace(namespace string)
- func (e *Event) SilencedBy(entries []*Silenced) []*Silenced
- func (m *Event) Size() (n int)
- func (e *Event) StorePrefix() string
- func (m *Event) String() string
- func (e *Event) SynthesizeExtras() map[string]interface{}
- func (this *Event) TestProto() github_com_golang_protobuf_proto.Message
- func (e *Event) URIPath() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (e *Event) Validate() error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventFace
- type EventFilter
- func (*EventFilter) Descriptor() ([]byte, []int)
- func (this *EventFilter) Equal(that interface{}) bool
- func (this *EventFilter) GetAction() string
- func (this *EventFilter) GetExpressions() []string
- func (this *EventFilter) GetObjectMeta() ObjectMeta
- func (this *EventFilter) GetRuntimeAssets() []string
- func (this *EventFilter) GetWhen() *TimeWindowWhen
- func (m *EventFilter) Marshal() (dAtA []byte, err error)
- func (m *EventFilter) MarshalTo(dAtA []byte) (int, error)
- func (this *EventFilter) Proto() github_com_golang_protobuf_proto.Message
- func (*EventFilter) ProtoMessage()
- func (m *EventFilter) Reset()
- func (f *EventFilter) SetNamespace(namespace string)
- func (m *EventFilter) Size() (n int)
- func (f *EventFilter) StorePrefix() string
- func (m *EventFilter) String() string
- func (this *EventFilter) TestProto() github_com_golang_protobuf_proto.Message
- func (f *EventFilter) URIPath() string
- func (m *EventFilter) Unmarshal(dAtA []byte) error
- func (f *EventFilter) Update(from *EventFilter, fields ...string) error
- func (f *EventFilter) Validate() error
- func (m *EventFilter) XXX_DiscardUnknown()
- func (m *EventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *EventFilter) XXX_Merge(src proto.Message)
- func (m *EventFilter) XXX_Size() int
- func (m *EventFilter) XXX_Unmarshal(b []byte) error
- type EventFilterFace
- type Extension
- func (*Extension) Descriptor() ([]byte, []int)
- func (this *Extension) Equal(that interface{}) bool
- func (this *Extension) GetObjectMeta() ObjectMeta
- func (this *Extension) GetURL() string
- func (m *Extension) Marshal() (dAtA []byte, err error)
- func (m *Extension) MarshalTo(dAtA []byte) (int, error)
- func (this *Extension) Proto() github_com_golang_protobuf_proto.Message
- func (*Extension) ProtoMessage()
- func (m *Extension) Reset()
- func (e *Extension) SetNamespace(namespace string)
- func (m *Extension) Size() (n int)
- func (e *Extension) StorePrefix() string
- func (m *Extension) String() string
- func (this *Extension) TestProto() github_com_golang_protobuf_proto.Message
- func (e *Extension) URIPath() string
- func (m *Extension) Unmarshal(dAtA []byte) error
- func (e *Extension) Validate() error
- func (m *Extension) XXX_DiscardUnknown()
- func (m *Extension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Extension) XXX_Merge(src proto.Message)
- func (m *Extension) XXX_Size() int
- func (m *Extension) XXX_Unmarshal(b []byte) error
- type ExtensionFace
- type Handler
- func FakeHandlerCommand(command string, args ...string) *Handler
- func FixtureHandler(name string) *Handler
- func FixtureSetHandler(name string, handlers ...string) *Handler
- func FixtureSocketHandler(name string, proto string) *Handler
- func NewHandler(meta ObjectMeta) *Handler
- func NewHandlerFromFace(that HandlerFace) *Handler
- func NewPopulatedHandler(r randyHandler, easy bool) *Handler
- func (*Handler) Descriptor() ([]byte, []int)
- func (this *Handler) Equal(that interface{}) bool
- func (this *Handler) GetCommand() string
- func (this *Handler) GetEnvVars() []string
- func (this *Handler) GetFilters() []string
- func (this *Handler) GetHandlers() []string
- func (this *Handler) GetMutator() string
- func (this *Handler) GetObjectMeta() ObjectMeta
- func (this *Handler) GetRuntimeAssets() []string
- func (this *Handler) GetSocket() *HandlerSocket
- func (this *Handler) GetTimeout() uint32
- func (this *Handler) GetType() string
- func (m *Handler) Marshal() (dAtA []byte, err error)
- func (m *Handler) MarshalTo(dAtA []byte) (int, error)
- func (this *Handler) Proto() github_com_golang_protobuf_proto.Message
- func (*Handler) ProtoMessage()
- func (m *Handler) Reset()
- func (h *Handler) SetNamespace(namespace string)
- func (m *Handler) Size() (n int)
- func (h *Handler) StorePrefix() string
- func (m *Handler) String() string
- func (this *Handler) TestProto() github_com_golang_protobuf_proto.Message
- func (h *Handler) URIPath() string
- func (m *Handler) Unmarshal(dAtA []byte) error
- func (h *Handler) Validate() error
- func (m *Handler) XXX_DiscardUnknown()
- func (m *Handler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Handler) XXX_Merge(src proto.Message)
- func (m *Handler) XXX_Size() int
- func (m *Handler) XXX_Unmarshal(b []byte) error
- type HandlerFace
- type HandlerSocket
- func (*HandlerSocket) Descriptor() ([]byte, []int)
- func (this *HandlerSocket) Equal(that interface{}) bool
- func (m *HandlerSocket) GetHost() string
- func (m *HandlerSocket) GetPort() uint32
- func (m *HandlerSocket) Marshal() (dAtA []byte, err error)
- func (m *HandlerSocket) MarshalTo(dAtA []byte) (int, error)
- func (*HandlerSocket) ProtoMessage()
- func (m *HandlerSocket) Reset()
- func (m *HandlerSocket) Size() (n int)
- func (m *HandlerSocket) String() string
- func (m *HandlerSocket) Unmarshal(dAtA []byte) error
- func (s *HandlerSocket) Validate() error
- func (m *HandlerSocket) XXX_DiscardUnknown()
- func (m *HandlerSocket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HandlerSocket) XXX_Merge(src proto.Message)
- func (m *HandlerSocket) XXX_Size() int
- func (m *HandlerSocket) XXX_Unmarshal(b []byte) error
- type HealthResponse
- type Hook
- func (*Hook) Descriptor() ([]byte, []int)
- func (this *Hook) Equal(that interface{}) bool
- func (m *Hook) GetDuration() float64
- func (m *Hook) GetExecuted() int64
- func (m *Hook) GetIssued() int64
- func (m *Hook) GetOutput() string
- func (m *Hook) GetStatus() int32
- func (m *Hook) Marshal() (dAtA []byte, err error)
- func (m *Hook) MarshalTo(dAtA []byte) (int, error)
- func (*Hook) ProtoMessage()
- func (m *Hook) Reset()
- func (h *Hook) SetNamespace(namespace string)
- func (m *Hook) Size() (n int)
- func (m *Hook) String() string
- func (h *Hook) URIPath() string
- func (m *Hook) Unmarshal(dAtA []byte) error
- func (h *Hook) Validate() error
- func (m *Hook) XXX_DiscardUnknown()
- func (m *Hook) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Hook) XXX_Merge(src proto.Message)
- func (m *Hook) XXX_Size() int
- func (m *Hook) XXX_Unmarshal(b []byte) error
- type HookConfig
- func (*HookConfig) Descriptor() ([]byte, []int)
- func (this *HookConfig) Equal(that interface{}) bool
- func (this *HookConfig) GetCommand() string
- func (this *HookConfig) GetObjectMeta() ObjectMeta
- func (this *HookConfig) GetStdin() bool
- func (this *HookConfig) GetTimeout() uint32
- func (m *HookConfig) Marshal() (dAtA []byte, err error)
- func (m *HookConfig) MarshalTo(dAtA []byte) (int, error)
- func (this *HookConfig) Proto() github_com_golang_protobuf_proto.Message
- func (*HookConfig) ProtoMessage()
- func (m *HookConfig) Reset()
- func (c *HookConfig) SetNamespace(namespace string)
- func (m *HookConfig) Size() (n int)
- func (c *HookConfig) StorePrefix() string
- func (m *HookConfig) String() string
- func (this *HookConfig) TestProto() github_com_golang_protobuf_proto.Message
- func (c *HookConfig) URIPath() string
- func (m *HookConfig) Unmarshal(dAtA []byte) error
- func (c *HookConfig) Validate() error
- func (m *HookConfig) XXX_DiscardUnknown()
- func (m *HookConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HookConfig) XXX_Merge(src proto.Message)
- func (m *HookConfig) XXX_Size() int
- func (m *HookConfig) XXX_Unmarshal(b []byte) error
- type HookConfigFace
- type HookList
- func (*HookList) Descriptor() ([]byte, []int)
- func (this *HookList) Equal(that interface{}) bool
- func (m *HookList) GetHooks() []string
- func (m *HookList) GetType() string
- func (m *HookList) Marshal() (dAtA []byte, err error)
- func (h *HookList) MarshalJSON() ([]byte, error)
- func (m *HookList) MarshalTo(dAtA []byte) (int, error)
- func (*HookList) ProtoMessage()
- func (m *HookList) Reset()
- func (m *HookList) Size() (n int)
- func (m *HookList) String() string
- func (m *HookList) Unmarshal(dAtA []byte) error
- func (h *HookList) UnmarshalJSON(b []byte) error
- func (h *HookList) Validate() error
- func (m *HookList) XXX_DiscardUnknown()
- func (m *HookList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HookList) XXX_Merge(src proto.Message)
- func (m *HookList) XXX_Size() int
- func (m *HookList) XXX_Unmarshal(b []byte) error
- type KeepaliveRecord
- func (*KeepaliveRecord) Descriptor() ([]byte, []int)
- func (this *KeepaliveRecord) Equal(that interface{}) bool
- func (this *KeepaliveRecord) GetObjectMeta() ObjectMeta
- func (this *KeepaliveRecord) GetTime() int64
- func (m *KeepaliveRecord) Marshal() (dAtA []byte, err error)
- func (m *KeepaliveRecord) MarshalTo(dAtA []byte) (int, error)
- func (this *KeepaliveRecord) Proto() github_com_golang_protobuf_proto.Message
- func (*KeepaliveRecord) ProtoMessage()
- func (m *KeepaliveRecord) Reset()
- func (m *KeepaliveRecord) Size() (n int)
- func (m *KeepaliveRecord) String() string
- func (this *KeepaliveRecord) TestProto() github_com_golang_protobuf_proto.Message
- func (m *KeepaliveRecord) Unmarshal(dAtA []byte) error
- func (m *KeepaliveRecord) XXX_DiscardUnknown()
- func (m *KeepaliveRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KeepaliveRecord) XXX_Merge(src proto.Message)
- func (m *KeepaliveRecord) XXX_Size() int
- func (m *KeepaliveRecord) XXX_Unmarshal(b []byte) error
- type KeepaliveRecordFace
- type MetricPoint
- func (*MetricPoint) Descriptor() ([]byte, []int)
- func (this *MetricPoint) Equal(that interface{}) bool
- func (m *MetricPoint) GetName() string
- func (m *MetricPoint) GetTags() []*MetricTag
- func (m *MetricPoint) GetTimestamp() int64
- func (m *MetricPoint) GetValue() float64
- func (m *MetricPoint) Marshal() (dAtA []byte, err error)
- func (m *MetricPoint) MarshalTo(dAtA []byte) (int, error)
- func (*MetricPoint) ProtoMessage()
- func (m *MetricPoint) Reset()
- func (m *MetricPoint) Size() (n int)
- func (m *MetricPoint) String() string
- func (m *MetricPoint) Unmarshal(dAtA []byte) error
- func (m *MetricPoint) XXX_DiscardUnknown()
- func (m *MetricPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MetricPoint) XXX_Merge(src proto.Message)
- func (m *MetricPoint) XXX_Size() int
- func (m *MetricPoint) XXX_Unmarshal(b []byte) error
- type MetricTag
- func (*MetricTag) Descriptor() ([]byte, []int)
- func (this *MetricTag) Equal(that interface{}) bool
- func (m *MetricTag) GetName() string
- func (m *MetricTag) GetValue() string
- func (m *MetricTag) Marshal() (dAtA []byte, err error)
- func (m *MetricTag) MarshalTo(dAtA []byte) (int, error)
- func (*MetricTag) ProtoMessage()
- func (m *MetricTag) Reset()
- func (m *MetricTag) Size() (n int)
- func (m *MetricTag) String() string
- func (m *MetricTag) Unmarshal(dAtA []byte) error
- func (m *MetricTag) XXX_DiscardUnknown()
- func (m *MetricTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MetricTag) XXX_Merge(src proto.Message)
- func (m *MetricTag) XXX_Size() int
- func (m *MetricTag) XXX_Unmarshal(b []byte) error
- type Metrics
- func (*Metrics) Descriptor() ([]byte, []int)
- func (this *Metrics) Equal(that interface{}) bool
- func (m *Metrics) GetHandlers() []string
- func (m *Metrics) GetPoints() []*MetricPoint
- func (m *Metrics) Marshal() (dAtA []byte, err error)
- func (m *Metrics) MarshalTo(dAtA []byte) (int, error)
- func (*Metrics) ProtoMessage()
- func (m *Metrics) Reset()
- func (m *Metrics) Size() (n int)
- func (m *Metrics) String() string
- func (m *Metrics) Unmarshal(dAtA []byte) error
- func (m *Metrics) Validate() error
- func (m *Metrics) XXX_DiscardUnknown()
- func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metrics) XXX_Merge(src proto.Message)
- func (m *Metrics) XXX_Size() int
- func (m *Metrics) XXX_Unmarshal(b []byte) error
- type MultitenantResource
- type Mutator
- func (*Mutator) Descriptor() ([]byte, []int)
- func (this *Mutator) Equal(that interface{}) bool
- func (this *Mutator) GetCommand() string
- func (this *Mutator) GetEnvVars() []string
- func (this *Mutator) GetObjectMeta() ObjectMeta
- func (this *Mutator) GetRuntimeAssets() []string
- func (this *Mutator) GetTimeout() uint32
- func (m *Mutator) Marshal() (dAtA []byte, err error)
- func (m *Mutator) MarshalTo(dAtA []byte) (int, error)
- func (this *Mutator) Proto() github_com_golang_protobuf_proto.Message
- func (*Mutator) ProtoMessage()
- func (m *Mutator) Reset()
- func (m *Mutator) SetNamespace(namespace string)
- func (m *Mutator) Size() (n int)
- func (m *Mutator) StorePrefix() string
- func (m *Mutator) String() string
- func (this *Mutator) TestProto() github_com_golang_protobuf_proto.Message
- func (m *Mutator) URIPath() string
- func (m *Mutator) Unmarshal(dAtA []byte) error
- func (m *Mutator) Update(from *Mutator, fields ...string) error
- func (m *Mutator) Validate() error
- func (m *Mutator) XXX_DiscardUnknown()
- func (m *Mutator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Mutator) XXX_Merge(src proto.Message)
- func (m *Mutator) XXX_Size() int
- func (m *Mutator) XXX_Unmarshal(b []byte) error
- type MutatorFace
- type Namespace
- func (*Namespace) Descriptor() ([]byte, []int)
- func (this *Namespace) Equal(that interface{}) bool
- func (m *Namespace) GetName() string
- func (n *Namespace) GetObjectMeta() ObjectMeta
- func (m *Namespace) Marshal() (dAtA []byte, err error)
- func (m *Namespace) MarshalTo(dAtA []byte) (int, error)
- func (*Namespace) ProtoMessage()
- func (m *Namespace) Reset()
- func (n *Namespace) SetNamespace(namespace string)
- func (m *Namespace) Size() (n int)
- func (n *Namespace) StorePrefix() string
- func (m *Namespace) String() string
- func (n *Namespace) URIPath() string
- func (m *Namespace) Unmarshal(dAtA []byte) error
- func (n *Namespace) Validate() error
- func (m *Namespace) XXX_DiscardUnknown()
- func (m *Namespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Namespace) XXX_Merge(src proto.Message)
- func (m *Namespace) XXX_Size() int
- func (m *Namespace) XXX_Unmarshal(b []byte) error
- type Network
- func (*Network) Descriptor() ([]byte, []int)
- func (this *Network) Equal(that interface{}) bool
- func (m *Network) GetInterfaces() []NetworkInterface
- func (m *Network) Marshal() (dAtA []byte, err error)
- func (m *Network) MarshalTo(dAtA []byte) (int, error)
- func (*Network) ProtoMessage()
- func (m *Network) Reset()
- func (m *Network) Size() (n int)
- func (m *Network) String() string
- func (m *Network) Unmarshal(dAtA []byte) error
- func (m *Network) XXX_DiscardUnknown()
- func (m *Network) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Network) XXX_Merge(src proto.Message)
- func (m *Network) XXX_Size() int
- func (m *Network) XXX_Unmarshal(b []byte) error
- type NetworkInterface
- func (*NetworkInterface) Descriptor() ([]byte, []int)
- func (this *NetworkInterface) Equal(that interface{}) bool
- func (m *NetworkInterface) GetAddresses() []string
- func (m *NetworkInterface) GetMAC() string
- func (m *NetworkInterface) GetName() string
- func (m *NetworkInterface) Marshal() (dAtA []byte, err error)
- func (m *NetworkInterface) MarshalTo(dAtA []byte) (int, error)
- func (*NetworkInterface) ProtoMessage()
- func (m *NetworkInterface) Reset()
- func (m *NetworkInterface) Size() (n int)
- func (m *NetworkInterface) String() string
- func (m *NetworkInterface) Unmarshal(dAtA []byte) error
- func (m *NetworkInterface) XXX_DiscardUnknown()
- func (m *NetworkInterface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NetworkInterface) XXX_Merge(src proto.Message)
- func (m *NetworkInterface) XXX_Size() int
- func (m *NetworkInterface) XXX_Unmarshal(b []byte) error
- type ObjectMeta
- func (*ObjectMeta) Descriptor() ([]byte, []int)
- func (this *ObjectMeta) Equal(that interface{}) bool
- func (m *ObjectMeta) GetAnnotations() map[string]string
- func (m *ObjectMeta) GetLabels() map[string]string
- func (m *ObjectMeta) GetName() string
- func (m *ObjectMeta) GetNamespace() string
- func (m *ObjectMeta) Marshal() (dAtA []byte, err error)
- func (m *ObjectMeta) MarshalTo(dAtA []byte) (int, error)
- func (*ObjectMeta) ProtoMessage()
- func (m *ObjectMeta) Reset()
- func (m *ObjectMeta) Size() (n int)
- func (m *ObjectMeta) String() string
- func (m *ObjectMeta) Unmarshal(dAtA []byte) error
- func (m *ObjectMeta) XXX_DiscardUnknown()
- func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ObjectMeta) XXX_Merge(src proto.Message)
- func (m *ObjectMeta) XXX_Size() int
- func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
- type ProxyRequests
- func (*ProxyRequests) Descriptor() ([]byte, []int)
- func (this *ProxyRequests) Equal(that interface{}) bool
- func (m *ProxyRequests) GetEntityAttributes() []string
- func (m *ProxyRequests) GetSplay() bool
- func (m *ProxyRequests) GetSplayCoverage() uint32
- func (m *ProxyRequests) Marshal() (dAtA []byte, err error)
- func (m *ProxyRequests) MarshalTo(dAtA []byte) (int, error)
- func (*ProxyRequests) ProtoMessage()
- func (m *ProxyRequests) Reset()
- func (m *ProxyRequests) Size() (n int)
- func (m *ProxyRequests) String() string
- func (m *ProxyRequests) Unmarshal(dAtA []byte) error
- func (p *ProxyRequests) Validate() error
- func (m *ProxyRequests) XXX_DiscardUnknown()
- func (m *ProxyRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProxyRequests) XXX_Merge(src proto.Message)
- func (m *ProxyRequests) XXX_Size() int
- func (m *ProxyRequests) XXX_Unmarshal(b []byte) error
- type Resource
- type Role
- func (*Role) Descriptor() ([]byte, []int)
- func (this *Role) Equal(that interface{}) bool
- func (this *Role) GetObjectMeta() ObjectMeta
- func (this *Role) GetRules() []Rule
- func (m *Role) Marshal() (dAtA []byte, err error)
- func (m *Role) MarshalTo(dAtA []byte) (int, error)
- func (this *Role) Proto() github_com_golang_protobuf_proto.Message
- func (*Role) ProtoMessage()
- func (m *Role) Reset()
- func (r *Role) SetNamespace(namespace string)
- func (m *Role) Size() (n int)
- func (r *Role) StorePrefix() string
- func (m *Role) String() string
- func (this *Role) TestProto() github_com_golang_protobuf_proto.Message
- func (r *Role) URIPath() string
- func (m *Role) Unmarshal(dAtA []byte) error
- func (r *Role) Validate() error
- func (m *Role) XXX_DiscardUnknown()
- func (m *Role) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Role) XXX_Merge(src proto.Message)
- func (m *Role) XXX_Size() int
- func (m *Role) XXX_Unmarshal(b []byte) error
- type RoleBinding
- func (*RoleBinding) Descriptor() ([]byte, []int)
- func (this *RoleBinding) Equal(that interface{}) bool
- func (this *RoleBinding) GetObjectMeta() ObjectMeta
- func (this *RoleBinding) GetRoleRef() RoleRef
- func (this *RoleBinding) GetSubjects() []Subject
- func (m *RoleBinding) Marshal() (dAtA []byte, err error)
- func (m *RoleBinding) MarshalTo(dAtA []byte) (int, error)
- func (this *RoleBinding) Proto() github_com_golang_protobuf_proto.Message
- func (*RoleBinding) ProtoMessage()
- func (m *RoleBinding) Reset()
- func (b *RoleBinding) SetNamespace(namespace string)
- func (m *RoleBinding) Size() (n int)
- func (b *RoleBinding) StorePrefix() string
- func (m *RoleBinding) String() string
- func (this *RoleBinding) TestProto() github_com_golang_protobuf_proto.Message
- func (b *RoleBinding) URIPath() string
- func (m *RoleBinding) Unmarshal(dAtA []byte) error
- func (b *RoleBinding) Validate() error
- func (m *RoleBinding) XXX_DiscardUnknown()
- func (m *RoleBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RoleBinding) XXX_Merge(src proto.Message)
- func (m *RoleBinding) XXX_Size() int
- func (m *RoleBinding) XXX_Unmarshal(b []byte) error
- type RoleBindingFace
- type RoleFace
- type RoleRef
- func (*RoleRef) Descriptor() ([]byte, []int)
- func (this *RoleRef) Equal(that interface{}) bool
- func (m *RoleRef) GetName() string
- func (m *RoleRef) GetType() string
- func (m *RoleRef) Marshal() (dAtA []byte, err error)
- func (m *RoleRef) MarshalTo(dAtA []byte) (int, error)
- func (*RoleRef) ProtoMessage()
- func (m *RoleRef) Reset()
- func (m *RoleRef) Size() (n int)
- func (m *RoleRef) String() string
- func (m *RoleRef) Unmarshal(dAtA []byte) error
- func (m *RoleRef) XXX_DiscardUnknown()
- func (m *RoleRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RoleRef) XXX_Merge(src proto.Message)
- func (m *RoleRef) XXX_Size() int
- func (m *RoleRef) XXX_Unmarshal(b []byte) error
- type Rule
- func (*Rule) Descriptor() ([]byte, []int)
- func (this *Rule) Equal(that interface{}) bool
- func (m *Rule) GetResourceNames() []string
- func (m *Rule) GetResources() []string
- func (m *Rule) GetVerbs() []string
- func (m *Rule) Marshal() (dAtA []byte, err error)
- func (m *Rule) MarshalTo(dAtA []byte) (int, error)
- func (*Rule) ProtoMessage()
- func (m *Rule) Reset()
- func (r Rule) ResourceMatches(requestedResource string) bool
- func (r Rule) ResourceNameMatches(requestedResourceName string) bool
- func (m *Rule) Size() (n int)
- func (m *Rule) String() string
- func (m *Rule) Unmarshal(dAtA []byte) error
- func (r Rule) VerbMatches(requestedVerb string) bool
- func (m *Rule) XXX_DiscardUnknown()
- func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Rule) XXX_Merge(src proto.Message)
- func (m *Rule) XXX_Size() int
- func (m *Rule) XXX_Unmarshal(b []byte) error
- type Silenced
- func (*Silenced) Descriptor() ([]byte, []int)
- func (this *Silenced) Equal(that interface{}) bool
- func (this *Silenced) GetBegin() int64
- func (this *Silenced) GetCheck() string
- func (this *Silenced) GetCreator() string
- func (this *Silenced) GetExpire() int64
- func (this *Silenced) GetExpireOnResolve() bool
- func (this *Silenced) GetObjectMeta() ObjectMeta
- func (this *Silenced) GetReason() string
- func (this *Silenced) GetSubscription() string
- func (m *Silenced) Marshal() (dAtA []byte, err error)
- func (m *Silenced) MarshalTo(dAtA []byte) (int, error)
- func (s *Silenced) Prepare(ctx context.Context)
- func (this *Silenced) Proto() github_com_golang_protobuf_proto.Message
- func (*Silenced) ProtoMessage()
- func (m *Silenced) Reset()
- func (s *Silenced) SetNamespace(namespace string)
- func (m *Silenced) Size() (n int)
- func (s *Silenced) StartSilence(currentTime int64) bool
- func (s *Silenced) StorePrefix() string
- func (m *Silenced) String() string
- func (this *Silenced) TestProto() github_com_golang_protobuf_proto.Message
- func (s *Silenced) URIPath() string
- func (m *Silenced) Unmarshal(dAtA []byte) error
- func (s *Silenced) Validate() error
- func (m *Silenced) XXX_DiscardUnknown()
- func (m *Silenced) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Silenced) XXX_Merge(src proto.Message)
- func (m *Silenced) XXX_Size() int
- func (m *Silenced) XXX_Unmarshal(b []byte) error
- type SilencedFace
- type Subject
- func (*Subject) Descriptor() ([]byte, []int)
- func (this *Subject) Equal(that interface{}) bool
- func (m *Subject) GetName() string
- func (m *Subject) GetType() string
- func (m *Subject) Marshal() (dAtA []byte, err error)
- func (m *Subject) MarshalTo(dAtA []byte) (int, error)
- func (*Subject) ProtoMessage()
- func (m *Subject) Reset()
- func (m *Subject) Size() (n int)
- func (m *Subject) String() string
- func (m *Subject) Unmarshal(dAtA []byte) error
- func (m *Subject) XXX_DiscardUnknown()
- func (m *Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Subject) XXX_Merge(src proto.Message)
- func (m *Subject) XXX_Size() int
- func (m *Subject) XXX_Unmarshal(b []byte) error
- type System
- func (*System) Descriptor() ([]byte, []int)
- func (this *System) Equal(that interface{}) bool
- func (m *System) GetArch() string
- func (m *System) GetHostname() string
- func (m *System) GetNetwork() Network
- func (m *System) GetOS() string
- func (m *System) GetPlatform() string
- func (m *System) GetPlatformFamily() string
- func (m *System) GetPlatformVersion() string
- func (m *System) Marshal() (dAtA []byte, err error)
- func (m *System) MarshalTo(dAtA []byte) (int, error)
- func (*System) ProtoMessage()
- func (m *System) Reset()
- func (m *System) Size() (n int)
- func (m *System) String() string
- func (m *System) Unmarshal(dAtA []byte) error
- func (m *System) XXX_DiscardUnknown()
- func (m *System) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *System) XXX_Merge(src proto.Message)
- func (m *System) XXX_Size() int
- func (m *System) XXX_Unmarshal(b []byte) error
- type TLSOptions
- func (*TLSOptions) Descriptor() ([]byte, []int)
- func (this *TLSOptions) Equal(that interface{}) bool
- func (m *TLSOptions) GetCertFile() string
- func (m *TLSOptions) GetInsecureSkipVerify() bool
- func (m *TLSOptions) GetKeyFile() string
- func (m *TLSOptions) GetTrustedCAFile() string
- func (m *TLSOptions) Marshal() (dAtA []byte, err error)
- func (m *TLSOptions) MarshalTo(dAtA []byte) (int, error)
- func (*TLSOptions) ProtoMessage()
- func (m *TLSOptions) Reset()
- func (m *TLSOptions) Size() (n int)
- func (m *TLSOptions) String() string
- func (t *TLSOptions) ToClientTLSConfig() (*tls.Config, error)
- func (t *TLSOptions) ToServerTLSConfig() (*tls.Config, error)
- func (m *TLSOptions) Unmarshal(dAtA []byte) error
- func (m *TLSOptions) XXX_DiscardUnknown()
- func (m *TLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TLSOptions) XXX_Merge(src proto.Message)
- func (m *TLSOptions) XXX_Size() int
- func (m *TLSOptions) XXX_Unmarshal(b []byte) error
- type TessenConfig
- func (*TessenConfig) Descriptor() ([]byte, []int)
- func (this *TessenConfig) Equal(that interface{}) bool
- func (t *TessenConfig) GetObjectMeta() ObjectMeta
- func (this *TessenConfig) GetOptOut() bool
- func (m *TessenConfig) Marshal() (dAtA []byte, err error)
- func (m *TessenConfig) MarshalTo(dAtA []byte) (int, error)
- func (this *TessenConfig) Proto() github_com_golang_protobuf_proto.Message
- func (*TessenConfig) ProtoMessage()
- func (m *TessenConfig) Reset()
- func (t *TessenConfig) SetNamespace(namespace string)
- func (m *TessenConfig) Size() (n int)
- func (t *TessenConfig) StorePrefix() string
- func (m *TessenConfig) String() string
- func (this *TessenConfig) TestProto() github_com_golang_protobuf_proto.Message
- func (t *TessenConfig) URIPath() string
- func (m *TessenConfig) Unmarshal(dAtA []byte) error
- func (t *TessenConfig) Validate() error
- func (m *TessenConfig) XXX_DiscardUnknown()
- func (m *TessenConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TessenConfig) XXX_Merge(src proto.Message)
- func (m *TessenConfig) XXX_Size() int
- func (m *TessenConfig) XXX_Unmarshal(b []byte) error
- type TessenConfigFace
- type TimeWindowDays
- func (*TimeWindowDays) Descriptor() ([]byte, []int)
- func (this *TimeWindowDays) Equal(that interface{}) bool
- func (m *TimeWindowDays) GetAll() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetFriday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetMonday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetSaturday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetSunday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetThursday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetTuesday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) GetWednesday() []*TimeWindowTimeRange
- func (m *TimeWindowDays) Marshal() (dAtA []byte, err error)
- func (m *TimeWindowDays) MarshalTo(dAtA []byte) (int, error)
- func (*TimeWindowDays) ProtoMessage()
- func (m *TimeWindowDays) Reset()
- func (m *TimeWindowDays) Size() (n int)
- func (m *TimeWindowDays) String() string
- func (m *TimeWindowDays) Unmarshal(dAtA []byte) error
- func (m *TimeWindowDays) XXX_DiscardUnknown()
- func (m *TimeWindowDays) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimeWindowDays) XXX_Merge(src proto.Message)
- func (m *TimeWindowDays) XXX_Size() int
- func (m *TimeWindowDays) XXX_Unmarshal(b []byte) error
- type TimeWindowTimeRange
- func (*TimeWindowTimeRange) Descriptor() ([]byte, []int)
- func (this *TimeWindowTimeRange) Equal(that interface{}) bool
- func (m *TimeWindowTimeRange) GetBegin() string
- func (m *TimeWindowTimeRange) GetEnd() string
- func (t *TimeWindowTimeRange) InWindow(current time.Time) (bool, error)
- func (m *TimeWindowTimeRange) Marshal() (dAtA []byte, err error)
- func (m *TimeWindowTimeRange) MarshalTo(dAtA []byte) (int, error)
- func (*TimeWindowTimeRange) ProtoMessage()
- func (m *TimeWindowTimeRange) Reset()
- func (m *TimeWindowTimeRange) Size() (n int)
- func (m *TimeWindowTimeRange) String() string
- func (m *TimeWindowTimeRange) Unmarshal(dAtA []byte) error
- func (t *TimeWindowTimeRange) Validate() error
- func (m *TimeWindowTimeRange) XXX_DiscardUnknown()
- func (m *TimeWindowTimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimeWindowTimeRange) XXX_Merge(src proto.Message)
- func (m *TimeWindowTimeRange) XXX_Size() int
- func (m *TimeWindowTimeRange) XXX_Unmarshal(b []byte) error
- type TimeWindowWhen
- func (*TimeWindowWhen) Descriptor() ([]byte, []int)
- func (this *TimeWindowWhen) Equal(that interface{}) bool
- func (m *TimeWindowWhen) GetDays() TimeWindowDays
- func (t *TimeWindowWhen) InWindows(current time.Time) (bool, error)
- func (t *TimeWindowWhen) MapTimeWindows() map[string][]*TimeWindowTimeRange
- func (m *TimeWindowWhen) Marshal() (dAtA []byte, err error)
- func (m *TimeWindowWhen) MarshalTo(dAtA []byte) (int, error)
- func (*TimeWindowWhen) ProtoMessage()
- func (m *TimeWindowWhen) Reset()
- func (m *TimeWindowWhen) Size() (n int)
- func (m *TimeWindowWhen) String() string
- func (m *TimeWindowWhen) Unmarshal(dAtA []byte) error
- func (t *TimeWindowWhen) Validate() error
- func (m *TimeWindowWhen) XXX_DiscardUnknown()
- func (m *TimeWindowWhen) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimeWindowWhen) XXX_Merge(src proto.Message)
- func (m *TimeWindowWhen) XXX_Size() int
- func (m *TimeWindowWhen) XXX_Unmarshal(b []byte) error
- type Tokens
- func (*Tokens) Descriptor() ([]byte, []int)
- func (this *Tokens) Equal(that interface{}) bool
- func (m *Tokens) GetAccess() string
- func (m *Tokens) GetExpiresAt() int64
- func (m *Tokens) GetRefresh() string
- func (m *Tokens) Marshal() (dAtA []byte, err error)
- func (m *Tokens) MarshalTo(dAtA []byte) (int, error)
- func (*Tokens) ProtoMessage()
- func (m *Tokens) Reset()
- func (m *Tokens) Size() (n int)
- func (m *Tokens) String() string
- func (m *Tokens) Unmarshal(dAtA []byte) error
- func (t *Tokens) Validate() error
- func (m *Tokens) XXX_DiscardUnknown()
- func (m *Tokens) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Tokens) XXX_Merge(src proto.Message)
- func (m *Tokens) XXX_Size() int
- func (m *Tokens) XXX_Unmarshal(b []byte) error
- type TypeMeta
- func (*TypeMeta) Descriptor() ([]byte, []int)
- func (this *TypeMeta) Equal(that interface{}) bool
- func (m *TypeMeta) GetAPIVersion() string
- func (m *TypeMeta) GetType() string
- func (m *TypeMeta) Marshal() (dAtA []byte, err error)
- func (m *TypeMeta) MarshalTo(dAtA []byte) (int, error)
- func (*TypeMeta) ProtoMessage()
- func (m *TypeMeta) Reset()
- func (m *TypeMeta) Size() (n int)
- func (m *TypeMeta) String() string
- func (m *TypeMeta) Unmarshal(dAtA []byte) error
- func (m *TypeMeta) XXX_DiscardUnknown()
- func (m *TypeMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TypeMeta) XXX_Merge(src proto.Message)
- func (m *TypeMeta) XXX_Size() int
- func (m *TypeMeta) XXX_Unmarshal(b []byte) error
- type User
- func (*User) Descriptor() ([]byte, []int)
- func (this *User) Equal(that interface{}) bool
- func (m *User) GetDisabled() bool
- func (m *User) GetGroups() []string
- func (u *User) GetObjectMeta() ObjectMeta
- func (m *User) GetPassword() string
- func (m *User) GetUsername() string
- func (m *User) Marshal() (dAtA []byte, err error)
- func (m *User) MarshalTo(dAtA []byte) (int, error)
- func (*User) ProtoMessage()
- func (m *User) Reset()
- func (u *User) SetNamespace(namespace string)
- func (m *User) Size() (n int)
- func (u *User) StorePrefix() string
- func (m *User) String() string
- func (u *User) URIPath() string
- func (m *User) Unmarshal(dAtA []byte) error
- func (u *User) Validate() error
- func (u *User) ValidatePassword() error
- func (m *User) XXX_DiscardUnknown()
- func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *User) XXX_Merge(src proto.Message)
- func (m *User) XXX_Size() int
- func (m *User) XXX_Unmarshal(b []byte) error
- type Version
Constants ¶
const ( // CheckRequestType is the message type string for check request. CheckRequestType = "check_request" // ChecksResource is the name of this resource type ChecksResource = "checks" // DefaultSplayCoverage is the default splay coverage for proxy check requests DefaultSplayCoverage = 90.0 // NagiosOutputMetricFormat is the accepted string to represent the output metric format of // Nagios Perf Data NagiosOutputMetricFormat = "nagios_perfdata" // GraphiteOutputMetricFormat is the accepted string to represent the output metric format of // Graphite Plain Text GraphiteOutputMetricFormat = "graphite_plaintext" // OpenTSDBOutputMetricFormat is the accepted string to represent the output metric format of // OpenTSDB Line OpenTSDBOutputMetricFormat = "opentsdb_line" // InfluxDBOutputMetricFormat is the accepted string to represent the output metric format of // InfluxDB Line InfluxDBOutputMetricFormat = "influxdb_line" )
const ( // AccessTokenString is the key name used to retrieve the access token string AccessTokenString key = iota // AccessTokenClaims contains the key name to retrieve the access token claims AccessTokenClaims // ClaimsKey contains key name to retrieve the jwt claims from context ClaimsKey // NamespaceKey contains the key name to retrieve the namespace from context NamespaceKey // RefreshTokenClaims contains the key name to retrieve the refresh token claims RefreshTokenClaims // RefreshTokenString contains the key name to retrieve the refresh token string RefreshTokenString // AuthorizationAttributesKey is the key name used to store authorization // attributes extracted from a request AuthorizationAttributesKey // StoreKey contains the key name to retrieve the etcd store from within a context StoreKey // PageContinueKey contains the continue token used in pagination PageContinueKey // PageSizeKey contains the page size used in pagination PageSizeKey )
const ( // APIGroupName is the group name for this API APIGroupName = "core" // APIVersion is the version for this API APIVersion = "v2" )
const ( // CoreEdition represents the Sensu Core Edition (CE) // <DEPRECATED> CoreEdition = "core" // EditionHeader represents the HTTP header containing the edition value // <DEPRECATED> EditionHeader = "Sensu-Edition" )
const ( // EntitiesResource is the name of this resource type EntitiesResource = "entities" // EntityAgentClass is the name of the class given to agent entities. EntityAgentClass = "agent" // EntityProxyClass is the name of the class given to proxy entities. EntityProxyClass = "proxy" // EntityBackendClass is the name of the class given to backend entities. EntityBackendClass = "backend" // Redacted is filled in for fields that contain sensitive information Redacted = "REDACTED" )
const ( // EventsResource is the name of this resource type EventsResource = "events" // EventFailingState indicates failing check result status EventFailingState = "failing" // EventFlappingState indicates a rapid change in check result status EventFlappingState = "flapping" // EventPassingState indicates successful check result status EventPassingState = "passing" )
const ( // EventFiltersResource is the name of this resource type EventFiltersResource = "filters" // EventFilterActionAllow is an action to allow events to pass through to the pipeline EventFilterActionAllow = "allow" // EventFilterActionDeny is an action to deny events from passing through to the pipeline EventFilterActionDeny = "deny" // DefaultEventFilterAction is the default action for filters DefaultEventFilterAction = EventFilterActionAllow )
const ( // HandlersResource is the name of this resource type HandlersResource = "handlers" // HandlerPipeType represents handlers that pipes event data // into arbitrary // commands via STDIN HandlerPipeType = "pipe" // HandlerSetType represents handlers that groups event handlers, making it // easy to manage groups of actions that should be executed for certain types // of events. HandlerSetType = "set" // HandlerTCPType represents handlers that send event data to a remote TCP // socket HandlerTCPType = "tcp" // HandlerUDPType represents handlers that send event data to a remote UDP // socket HandlerUDPType = "udp" // HandlerGRPCType is a special kind of handler that represents an extension HandlerGRPCType = "grpc" )
const ( // HooksResource is the name of this resource type HooksResource = "hooks" // HookRequestType is the message type string for hook request. HookRequestType = "hook_request" )
const ( // NamespaceTypeAll represents an empty namespace, used to represent a request // across all namespaces NamespaceTypeAll = "" // NamespacesResource is the name of this resource type NamespacesResource = "namespaces" )
const ( // ClusterRolesResource is the name of this resource type ClusterRolesResource = "clusterroles" // ClusterRoleBindingsResource is the name of this resource type ClusterRoleBindingsResource = "clusterrolebindings" // RolesResource is the name of this resource type RolesResource = "roles" // RoleBindingsResource is the name of this resource type RoleBindingsResource = "rolebindings" // ResourceAll represents all possible resources ResourceAll = "*" // VerbAll represents all possible verbs VerbAll = "*" // GroupType represents a group object in a subject GroupType = "Group" // UserType represents a user object in a subject UserType = "User" // LocalSelfUserResource represents a local user trying to view itself // or change its password LocalSelfUserResource = "localselfuser" )
const ( // LowerBound is the minimum interval that tessen will phone home, in seconds LowerBound = 60 // UpperBound is the maximum interval that tessen will phone home, in seconds UpperBound = 21600 // DefaultTessenInterval is the default interval at which tessen will phone home, in seconds DefaultTessenInterval = 1800 // TessenResource is the name of this resource type TessenResource = "tessen" )
const AgentHandshakeType = "agent_handshake"
AgentHandshakeType is the message type string for an AgentHandshake
const (
// AssetsResource is the name of this resource type
AssetsResource = "assets"
)
const BackendHandshakeType = "backend_handshake"
BackendHandshakeType is the message type string for a BackendHandshake
const DefaultKeepaliveTimeout = 120
DefaultKeepaliveTimeout specifies the default keepalive timeout
const (
// ExtensionsResource is the name of this resource type
ExtensionsResource = "extensions"
)
const (
// MutatorsResource is the name of this resource type
MutatorsResource = "mutators"
)
const PaginationContinueHeader = "Sensu-Continue"
PaginationContinueHeader is the name of the header used by the API to return a potential continue token when paginating.
const (
// SilencedResource is the name of this resource type
SilencedResource = "silenced"
)
const (
// UsersResource is the name of this resource type
UsersResource = "users"
)
Variables ¶
var ( ErrInvalidLengthAdhoc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAdhoc = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthAny = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAny = fmt.Errorf("proto: integer overflow") )
var ( // AssetNameRegexStr used to validate name of asset AssetNameRegexStr = `[a-z0-9\/\_\.\-]+` // AssetNameRegex used to validate name of asset AssetNameRegex = regexp.MustCompile("^" + AssetNameRegexStr + "$") )
var ( ErrInvalidLengthAsset = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAsset = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAuthentication = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCheck = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthEntity = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEntity = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvent = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthExtension = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowExtension = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthFilter = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowFilter = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthHandler = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHandler = fmt.Errorf("proto: integer overflow") )
var ( // CheckHookRegexStr used to validate type of check hook CheckHookRegexStr = `([0-9]|[1-9][0-9]|1[0-9][0-9]|2[0-4][0-9]|25[0-5])` // CheckHookRegex used to validate type of check hook CheckHookRegex = regexp.MustCompile("^" + CheckHookRegexStr + "$") // Severities used to validate type of check hook Severities = []string{"ok", "warning", "critical", "unknown", "non-zero"} )
var ( ErrInvalidLengthHook = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHook = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthKeepalive = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowKeepalive = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetrics = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthMutator = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMutator = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNamespace = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthRbac = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRbac = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthSilenced = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSilenced = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthTessen = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTessen = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthTimeWindow = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTimeWindow = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthTls = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTls = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthUser = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowUser = fmt.Errorf("proto: integer overflow") )
var CommonCoreResources = []string{
"assets",
"checks",
"entities",
"extensions",
"events",
"filters",
"handlers",
"hooks",
"mutators",
"silenced",
}
CommonCoreResources represents the common "core" resources found in a namespace
var ( // DefaultCipherSuites overrides the default cipher suites in order to disable // CBC suites (Lucky13 attack) this means TLS 1.1 can't work (no GCM) // additionally, we should only use perfect forward secrecy ciphers DefaultCipherSuites = []uint16{ tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384, tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384, tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256, tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, tls.TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305, tls.TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305, } )
var DefaultRedactFields = []string{"password", "passwd", "pass", "api_key",
"api_token", "access_key", "secret_key", "private_key", "secret"}
DefaultRedactFields contains the default fields to redact
var ( // EventFilterAllActions is a list of actions that can be used by filters EventFilterAllActions = []string{ EventFilterActionAllow, EventFilterActionDeny, } )
var NameRegex = regexp.MustCompile(`\A[\w\.\-]+\z`)
NameRegex is used to validate the name of a resource
var OutputMetricFormats = []string{NagiosOutputMetricFormat, GraphiteOutputMetricFormat, OpenTSDBOutputMetricFormat, InfluxDBOutputMetricFormat}
OutputMetricFormats represents all the accepted output_metric_format's a check can have
var StrictNameRegex = regexp.MustCompile(`\A[a-z0-9\_\.\-]+\z`)
StrictNameRegex is used to validate names of resources using a strict subset of charset.
var SubscriptionNameRegex = regexp.MustCompile(`\A[\w\.\-]+\:?[\w\.\-]+\z`)
SubscriptionNameRegex is used to validate the name of a subscription, which can contain a single ":" character in case of an entity subscription (e.g. entity:foo)
var URLPrefix = path.Join("/api", APIGroupName, APIVersion)
URLPrefix is the URL prefix of this API
Functions ¶
func AssetFields ¶
AssetFields returns a set of fields that represent that resource
func CheckConfigFields ¶
CheckConfigFields returns a set of fields that represent that resource
func ClusterRoleBindingFields ¶
ClusterRoleBindingFields returns a set of fields that represent that resource
func ClusterRoleFields ¶
ClusterRoleFields returns a set of fields that represent that resource
func ContextNamespace ¶
ContextNamespace returns the namespace injected in the context
func EntityFields ¶
EntityFields returns a set of fields that represent that resource
func EnvVarsToMap ¶
EnvVarsToMap converts a list of FOO=BAR key-value pairs into a map.
func EventFields ¶
EventFields returns a set of fields that represent that resource
func EventFilterFields ¶
EventFilterFields returns a set of fields that represent that resource
func EventsByLastOk ¶
EventsByLastOk can be used to sort a given collection of events by time it last received an OK status.
func EventsBySeverity ¶
EventsBySeverity can be used to sort a given collection of events by check status and timestamp.
func EventsByTimestamp ¶
EventsByTimestamp can be used to sort a given collection of events by time it occurred.
func ExtensionFields ¶
ExtensionFields returns a set of fields that represent that resource
func GetEntitySubscription ¶
GetEntitySubscription returns the entity subscription, using the format "entity:entityName"
func HandlerFields ¶
HandlerFields returns a set of fields that represent that resource
func HookConfigFields ¶
HookConfigFields returns a set of fields that represent that resource
func LoadCACerts ¶
LoadCACerts takes the path to a certificate bundle file in PEM format and try to create a x509.CertPool out of it.
func MutatorFields ¶
MutatorFields returns a set of fields that represent that resource
func NamespaceFields ¶
NamespaceFields returns a set of fields that represent that resource
func PageContinueFromContext ¶
PageContinueFromContext returns the continue token stored in the given context, if any. Returns "" if none is found.
func PageSizeFromContext ¶
PageSizeFromContext returns the page size stored in the given context, if any. Returns 0 if none is found, typically meaning "unlimited" page size.
func RoleBindingFields ¶
RoleBindingFields returns a set of fields that represent that resource
func RoleFields ¶
RoleFields returns a set of fields that represent that resource
func SetContextFromResource ¶
func SetContextFromResource(ctx context.Context, r MultitenantResource) context.Context
SetContextFromResource takes a context and a multi-tenant resource, adds the namespace to the context, and returns the udpated context
func SilencedFields ¶
SilencedFields returns a set of fields that represent that resource
func SilencedName ¶
SilencedName returns the canonical name for a silenced entry. It returns non-nil error if both subscription and check are empty strings.
func SortCheckConfigsByName ¶
func SortCheckConfigsByName(es []*CheckConfig, asc bool) sort.Interface
SortCheckConfigsByName can be used to sort a given collection of checks by their names.
func SortCheckConfigsByPredicate ¶
func SortCheckConfigsByPredicate(cs []*CheckConfig, fn cmpCheckConfig) sort.Interface
SortCheckConfigsByPredicate can be used to sort a given collection using a given predicate.
func SortEntitiesByID ¶
SortEntitiesByID can be used to sort a given collection of entities by their IDs.
func SortEntitiesByLastSeen ¶
SortEntitiesByLastSeen can be used to sort a given collection of entities by last time each was seen.
func SortEntitiesByPredicate ¶
SortEntitiesByPredicate can be used to sort a given collection using a given predicate.
func SortHandlersByName ¶
SortHandlersByName is used to sort a given collection of handlers by their names.
func SortHandlersByPredicate ¶
SortHandlersByPredicate is used to sort a given collection using a given predicate.
func SortSilencedByBegin ¶
SortSilencedByBegin can be used to sort a given collection by their begin timestamp.
func SortSilencedByName ¶
SortSilencedByName can be used to sort a given collection by their names.
func SortSilencedByPredicate ¶
SortSilencedByPredicate can be used to sort a given collection using a given predicate.
func StandardClaims ¶
func StandardClaims(subject string) jwt.StandardClaims
StandardClaims returns an initialized jwt.StandardClaims with the subject
func UserFields ¶
UserFields returns a set of fields that represent that resource
func ValidateAssetName ¶
ValidateAssetName validates that asset's name is valid
func ValidateEnvVars ¶
ValidateEnvVars ensures that all the environment variables are well-formed. Vars should be of the form FOO=BAR.
func ValidateInterval ¶
ValidateInterval returns an error if the tessen interval is not within the upper and lower bound limits
func ValidateName ¶
ValidateName validates the name of an element so it's not empty and it does not contains specical characters. Compatible with Sensu 1.0.
func ValidateNameStrict ¶
ValidateNameStrict validates the name of an element so it's not empty and it does not contains specical characters. Not compatible with Sensu 1.0 resources.
func ValidateOutputMetricFormat ¶
ValidateOutputMetricFormat returns an error if the string is not a valid metric format
func ValidateSubscriptionName ¶
ValidateSubscriptionName validates the name of a subscription so it's not empty and it does not contains special characters except for an optional ":"
Types ¶
type AdhocRequest ¶
type AdhocRequest struct { // Subscriptions is the list of entity subscriptions. Subscriptions []string `protobuf:"bytes,2,rep,name=subscriptions" json:"subscriptions,omitempty"` // Creator is the author of the adhoc request. Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"` // Reason is used to provide context to the request. Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"` // Metadata contains the name, namespace, labels and annotations of the AdhocCheck ObjectMeta `protobuf:"bytes,5,opt,name=metadata,embedded=metadata" json:"metadata"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func FixtureAdhocRequest ¶
func FixtureAdhocRequest(name string, subscriptions []string) *AdhocRequest
FixtureAdhocRequest returns a testing fixture for an AdhocRequest struct.
func NewPopulatedAdhocRequest ¶
func NewPopulatedAdhocRequest(r randyAdhoc, easy bool) *AdhocRequest
func (*AdhocRequest) Descriptor ¶
func (*AdhocRequest) Descriptor() ([]byte, []int)
func (*AdhocRequest) Equal ¶
func (this *AdhocRequest) Equal(that interface{}) bool
func (*AdhocRequest) GetCreator ¶
func (m *AdhocRequest) GetCreator() string
func (*AdhocRequest) GetReason ¶
func (m *AdhocRequest) GetReason() string
func (*AdhocRequest) GetSubscriptions ¶
func (m *AdhocRequest) GetSubscriptions() []string
func (*AdhocRequest) Marshal ¶
func (m *AdhocRequest) Marshal() (dAtA []byte, err error)
func (*AdhocRequest) ProtoMessage ¶
func (*AdhocRequest) ProtoMessage()
func (*AdhocRequest) Reset ¶
func (m *AdhocRequest) Reset()
func (*AdhocRequest) SetNamespace ¶
func (a *AdhocRequest) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*AdhocRequest) Size ¶
func (m *AdhocRequest) Size() (n int)
func (*AdhocRequest) StorePrefix ¶
func (a *AdhocRequest) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*AdhocRequest) String ¶
func (m *AdhocRequest) String() string
func (*AdhocRequest) URIPath ¶
func (a *AdhocRequest) URIPath() string
URIPath is the URI path component to the adhoc request.
func (*AdhocRequest) Unmarshal ¶
func (m *AdhocRequest) Unmarshal(dAtA []byte) error
func (*AdhocRequest) Validate ¶
func (a *AdhocRequest) Validate() error
Validate returns an error if the name is not provided.
func (*AdhocRequest) XXX_DiscardUnknown ¶
func (m *AdhocRequest) XXX_DiscardUnknown()
func (*AdhocRequest) XXX_Marshal ¶
func (m *AdhocRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AdhocRequest) XXX_Merge ¶
func (dst *AdhocRequest) XXX_Merge(src proto.Message)
func (*AdhocRequest) XXX_Size ¶
func (m *AdhocRequest) XXX_Size() int
func (*AdhocRequest) XXX_Unmarshal ¶
func (m *AdhocRequest) XXX_Unmarshal(b []byte) error
type AgentHandshake ¶
type AgentHandshake Entity
An AgentHandshake is the first message sent by a Backend on a Transport in a Session.
type Any ¶
type Any struct { TypeUrl string `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedAny ¶
func (*Any) Descriptor ¶
func (*Any) GetTypeUrl ¶
func (*Any) ProtoMessage ¶
func (*Any) ProtoMessage()
func (*Any) XXX_DiscardUnknown ¶
func (m *Any) XXX_DiscardUnknown()
func (*Any) XXX_Unmarshal ¶
type Asset ¶
type Asset struct { // URL is the location of the asset URL string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` // Sha512 is the SHA-512 checksum of the asset Sha512 string `protobuf:"bytes,3,opt,name=sha512,proto3" json:"sha512,omitempty"` // Filters are a collection of sensu queries, used by the system to determine // if the asset should be installed. If more than one filter is present the // queries are joined by the "AND" operator. Filters []string `protobuf:"bytes,5,rep,name=filters" json:"filters"` // Metadata contains the name, namespace, labels and annotations of the asset ObjectMeta `protobuf:"bytes,8,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Asset defines an asset agents install as a dependency for a check.
func FixtureAsset ¶
FixtureAsset given a name returns a valid asset for use in tests
func NewAssetFromFace ¶
func NewPopulatedAsset ¶
func (*Asset) Descriptor ¶
func (*Asset) GetFilters ¶
func (*Asset) GetObjectMeta ¶
func (this *Asset) GetObjectMeta() ObjectMeta
func (*Asset) Proto ¶
func (this *Asset) Proto() github_com_golang_protobuf_proto.Message
func (*Asset) ProtoMessage ¶
func (*Asset) ProtoMessage()
func (*Asset) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Asset) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Asset) TestProto ¶
func (this *Asset) TestProto() github_com_golang_protobuf_proto.Message
func (*Asset) XXX_DiscardUnknown ¶
func (m *Asset) XXX_DiscardUnknown()
func (*Asset) XXX_Marshal ¶
func (*Asset) XXX_Unmarshal ¶
type AssetFace ¶
type AssetFace interface { Proto() github_com_golang_protobuf_proto.Message GetURL() string GetSha512() string GetFilters() []string GetObjectMeta() ObjectMeta }
type AuthProvider ¶
type AuthProvider interface { // Authenticate attempts to authenticate a user with its username and password Authenticate(ctx context.Context, username, password string) (*Claims, error) // Refresh renews the user claims with the provider claims Refresh(ctx context.Context, providerClaims AuthProviderClaims) (*Claims, error) // GetObjectMeta returns the object metadata for the provider GetObjectMeta() ObjectMeta // Name returns the provider name (e.g. default) Name() string // StorePrefix gives the path prefix to this resource in the store StorePrefix() string // Type returns the provider type (e.g. ldap) Type() string // URIPath gives the path to the provider URIPath() string // Validate checks if the fields in the provider are valid Validate() error // SetNamespace sets the namespace of the resource. SetNamespace(string) }
AuthProvider represents an abstracted authentication provider
type AuthProviderClaims ¶
type AuthProviderClaims struct { // ProviderID used to login the user ProviderID string `json:"provider_id"` // UserID assigned to the user by the provider UserID string `json:"user_id"` }
AuthProviderClaims contains information from the authentication provider
type BackendHandshake ¶
type BackendHandshake struct{}
A BackendHandshake is the first message sent by a Backend on a Transport in a Session.
type ByExecuted ¶
type ByExecuted []CheckHistory
ByExecuted implements the sort.Interface for []CheckHistory based on the Executed field.
Example:
sort.Sort(ByExecuted(check.History))
func (ByExecuted) Len ¶
func (b ByExecuted) Len() int
func (ByExecuted) Less ¶
func (b ByExecuted) Less(i, j int) bool
func (ByExecuted) Swap ¶
func (b ByExecuted) Swap(i, j int)
type Check ¶
type Check struct { // Command is the command to be executed. Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` // Handlers are the event handler for the check (incidents and/or metrics). Handlers []string `protobuf:"bytes,3,rep,name=handlers" json:"handlers"` // HighFlapThreshold is the flap detection high threshold (% state change) // for the check. Sensu uses the same flap detection algorithm as Nagios. HighFlapThreshold uint32 `protobuf:"varint,4,opt,name=high_flap_threshold,json=highFlapThreshold,proto3" json:"high_flap_threshold"` // Interval is the interval, in seconds, at which the check should be run. Interval uint32 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval"` // LowFlapThreshold is the flap detection low threshold (% state change) for // the check. Sensu uses the same flap detection algorithm as Nagios. LowFlapThreshold uint32 `protobuf:"varint,6,opt,name=low_flap_threshold,json=lowFlapThreshold,proto3" json:"low_flap_threshold"` // Publish indicates if check requests are published for the check Publish bool `protobuf:"varint,9,opt,name=publish,proto3" json:"publish"` // RuntimeAssets are a list of assets required to execute check. RuntimeAssets []string `protobuf:"bytes,10,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"` // Subscriptions is the list of subscribers for the check. Subscriptions []string `protobuf:"bytes,11,rep,name=subscriptions" json:"subscriptions"` // Sources indicates the name of the entity representing an external // resource ProxyEntityName string `protobuf:"bytes,13,opt,name=proxy_entity_name,json=proxyEntityName,proto3" json:"proxy_entity_name"` // CheckHooks is the list of check hooks for the check CheckHooks []HookList `protobuf:"bytes,14,rep,name=check_hooks,json=checkHooks" json:"check_hooks"` // STDIN indicates if the check command accepts JSON via stdin from the // agent Stdin bool `protobuf:"varint,15,opt,name=stdin,proto3" json:"stdin"` // Subdue represents one or more time windows when the check should be // subdued. Subdue *TimeWindowWhen `protobuf:"bytes,16,opt,name=subdue" json:"subdue"` // Cron is the cron string at which the check should be run. Cron string `protobuf:"bytes,17,opt,name=cron,proto3" json:"cron,omitempty"` // TTL represents the length of time in seconds for which a check result is // valid. Ttl int64 `protobuf:"varint,18,opt,name=ttl,proto3" json:"ttl"` // Timeout is the timeout, in seconds, at which the check has to run Timeout uint32 `protobuf:"varint,19,opt,name=timeout,proto3" json:"timeout"` // ProxyRequests represents a request to execute a proxy check ProxyRequests *ProxyRequests `protobuf:"bytes,20,opt,name=proxy_requests,json=proxyRequests" json:"proxy_requests,omitempty"` // RoundRobin enables round-robin scheduling if set true. RoundRobin bool `protobuf:"varint,21,opt,name=round_robin,json=roundRobin,proto3" json:"round_robin"` // Duration of execution Duration float64 `protobuf:"fixed64,22,opt,name=duration,proto3" json:"duration,omitempty"` // Executed describes the time in which the check request was executed Executed int64 `protobuf:"varint,23,opt,name=executed,proto3" json:"executed"` // History is the check state history. History []CheckHistory `protobuf:"bytes,24,rep,name=history" json:"history"` // Issued describes the time in which the check request was issued Issued int64 `protobuf:"varint,25,opt,name=issued,proto3" json:"issued"` // Output from the execution of Command Output string `protobuf:"bytes,26,opt,name=output,proto3" json:"output"` // State provides handlers with more information about the state change State string `protobuf:"bytes,27,opt,name=state,proto3" json:"state,omitempty"` // Status is the exit status code produced by the check Status uint32 `protobuf:"varint,28,opt,name=status,proto3" json:"status"` // TotalStateChange indicates the total state change percentage for the // check's history TotalStateChange uint32 `protobuf:"varint,29,opt,name=total_state_change,json=totalStateChange,proto3" json:"total_state_change"` // LastOK displays last time this check was ok; if event status is 0 this is // set to timestamp LastOK int64 `protobuf:"varint,30,opt,name=last_ok,json=lastOk,proto3" json:"last_ok"` // Occurrences indicates the number of times an event has occurred for a // client/check pair with the same check status Occurrences int64 `protobuf:"varint,31,opt,name=occurrences,proto3" json:"occurrences"` // OccurrencesWatermark indicates the high water mark tracking number of // occurrences at the current severity OccurrencesWatermark int64 `protobuf:"varint,32,opt,name=occurrences_watermark,json=occurrencesWatermark,proto3" json:"occurrences_watermark"` // Silenced is a list of silenced entry ids (subscription and check name) Silenced []string `protobuf:"bytes,33,rep,name=silenced" json:"silenced,omitempty"` // Hooks describes the results of multiple hooks; if event is associated to // hook execution. Hooks []*Hook `protobuf:"bytes,34,rep,name=hooks" json:"hooks,omitempty"` // OutputOutputMetricFormat is the metric protocol that the check's output // will be expected to follow in order to be extracted. OutputMetricFormat string `protobuf:"bytes,35,opt,name=output_metric_format,json=outputMetricFormat,proto3" json:"output_metric_format"` // OutputOutputMetricHandlers is the list of event handlers that will // respond to metrics that have been extracted from the check. OutputMetricHandlers []string `protobuf:"bytes,36,rep,name=output_metric_handlers,json=outputMetricHandlers" json:"output_metric_handlers"` // EnvVars is the list of environment variables to set for the check's // execution environment. EnvVars []string `protobuf:"bytes,37,rep,name=env_vars,json=envVars" json:"env_vars"` // Metadata contains the name, namespace, labels and annotations of the // check ObjectMeta `protobuf:"bytes,38,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // MaxOutputSize is the maximum size in bytes that will be stored for check // output. If check output is larger than MaxOutputSize, it will be // truncated when stored. Filters, mutators, and handlers will still have // access to the full check output at the time the event occurs. MaxOutputSize int64 `protobuf:"varint,39,opt,name=max_output_size,json=maxOutputSize,proto3" json:"max_output_size,omitempty"` // DiscardOutput causes agents to discard check output. No check output is // written to the backend, but metrics extraction is still performed. DiscardOutput bool `protobuf:"varint,40,opt,name=discard_output,json=discardOutput,proto3" json:"discard_output,omitempty"` // ExtendedAttributes store serialized arbitrary JSON-encoded data ExtendedAttributes []byte `protobuf:"bytes,99,opt,name=ExtendedAttributes,proto3" json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A Check is a check specification and optionally the results of the check's execution.
func FixtureCheck ¶
FixtureCheck returns a fixture for a Check object.
func NewCheck ¶
func NewCheck(c *CheckConfig) *Check
NewCheck creates a new Check. It copies the fields from CheckConfig that match with Check's fields.
Because CheckConfig uses extended attributes, embedding CheckConfig was deemed to be too complicated, due to interactions between promoted methods and encoding/json.
func NewCheckFromFace ¶
func NewPopulatedCheck ¶
func (*Check) Descriptor ¶
func (*Check) GetCheckHooks ¶
func (*Check) GetCommand ¶
func (*Check) GetDiscardOutput ¶
func (*Check) GetDuration ¶
func (*Check) GetEnvVars ¶
func (*Check) GetExecuted ¶
func (*Check) GetExtendedAttributes ¶
func (*Check) GetHandlers ¶
func (*Check) GetHighFlapThreshold ¶
func (*Check) GetHistory ¶
func (this *Check) GetHistory() []CheckHistory
func (*Check) GetInterval ¶
func (*Check) GetLowFlapThreshold ¶
func (*Check) GetMaxOutputSize ¶
func (*Check) GetObjectMeta ¶
func (this *Check) GetObjectMeta() ObjectMeta
func (*Check) GetOccurrences ¶
func (*Check) GetOccurrencesWatermark ¶
func (*Check) GetOutputMetricFormat ¶
func (*Check) GetOutputMetricHandlers ¶
func (*Check) GetProxyEntityName ¶
func (*Check) GetProxyRequests ¶
func (this *Check) GetProxyRequests() *ProxyRequests
func (*Check) GetPublish ¶
func (*Check) GetRoundRobin ¶
func (*Check) GetRuntimeAssets ¶
func (*Check) GetSilenced ¶
func (*Check) GetSubdue ¶
func (this *Check) GetSubdue() *TimeWindowWhen
func (*Check) GetSubscriptions ¶
func (*Check) GetTimeout ¶
func (*Check) GetTotalStateChange ¶
func (*Check) MarshalJSON ¶
MarshalJSON implements the json.Marshaler interface.
func (*Check) MergeWith ¶
MergeWith updates the current Check with the history of the check given as an argument, updating the current check's history appropriately.
func (*Check) Proto ¶
func (this *Check) Proto() github_com_golang_protobuf_proto.Message
func (*Check) ProtoMessage ¶
func (*Check) ProtoMessage()
func (*Check) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Check) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Check) TestProto ¶
func (this *Check) TestProto() github_com_golang_protobuf_proto.Message
func (*Check) XXX_DiscardUnknown ¶
func (m *Check) XXX_DiscardUnknown()
func (*Check) XXX_Marshal ¶
func (*Check) XXX_Unmarshal ¶
type CheckConfig ¶
type CheckConfig struct { // Command is the command to be executed. Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` // Handlers are the event handler for the check (incidents and/or metrics). Handlers []string `protobuf:"bytes,3,rep,name=handlers" json:"handlers"` // HighFlapThreshold is the flap detection high threshold (% state change) // for the check. Sensu uses the same flap detection algorithm as Nagios. HighFlapThreshold uint32 `protobuf:"varint,4,opt,name=high_flap_threshold,json=highFlapThreshold,proto3" json:"high_flap_threshold"` // Interval is the interval, in seconds, at which the check should be run. Interval uint32 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval"` // LowFlapThreshold is the flap detection low threshold (% state change) for // the check. Sensu uses the same flap detection algorithm as Nagios. LowFlapThreshold uint32 `protobuf:"varint,6,opt,name=low_flap_threshold,json=lowFlapThreshold,proto3" json:"low_flap_threshold"` // Publish indicates if check requests are published for the check Publish bool `protobuf:"varint,9,opt,name=publish,proto3" json:"publish"` // RuntimeAssets are a list of assets required to execute check. RuntimeAssets []string `protobuf:"bytes,10,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"` // Subscriptions is the list of subscribers for the check. Subscriptions []string `protobuf:"bytes,11,rep,name=subscriptions" json:"subscriptions"` // ExtendedAttributes store serialized arbitrary JSON-encoded data ExtendedAttributes []byte `protobuf:"bytes,12,opt,name=ExtendedAttributes,proto3" json:"-"` // Sources indicates the name of the entity representing an external // resource ProxyEntityName string `protobuf:"bytes,13,opt,name=proxy_entity_name,json=proxyEntityName,proto3" json:"proxy_entity_name"` // CheckHooks is the list of check hooks for the check CheckHooks []HookList `protobuf:"bytes,14,rep,name=check_hooks,json=checkHooks" json:"check_hooks"` // STDIN indicates if the check command accepts JSON via stdin from the // agent Stdin bool `protobuf:"varint,15,opt,name=stdin,proto3" json:"stdin"` // Subdue represents one or more time windows when the check should be // subdued. Subdue *TimeWindowWhen `protobuf:"bytes,16,opt,name=subdue" json:"subdue"` // Cron is the cron string at which the check should be run. Cron string `protobuf:"bytes,17,opt,name=cron,proto3" json:"cron,omitempty"` // TTL represents the length of time in seconds for which a check result is // valid. Ttl int64 `protobuf:"varint,18,opt,name=ttl,proto3" json:"ttl"` // Timeout is the timeout, in seconds, at which the check has to run Timeout uint32 `protobuf:"varint,19,opt,name=timeout,proto3" json:"timeout"` // ProxyRequests represents a request to execute a proxy check ProxyRequests *ProxyRequests `protobuf:"bytes,20,opt,name=proxy_requests,json=proxyRequests" json:"proxy_requests,omitempty"` // RoundRobin enables round-robin scheduling if set true. RoundRobin bool `protobuf:"varint,21,opt,name=round_robin,json=roundRobin,proto3" json:"round_robin"` // OutputOutputMetricFormat is the metric protocol that the check's output // will be expected to follow in order to be extracted. OutputMetricFormat string `protobuf:"bytes,22,opt,name=output_metric_format,json=outputMetricFormat,proto3" json:"output_metric_format"` // OutputOutputMetricHandlers is the list of event handlers that will // respond to metrics that have been extracted from the check. OutputMetricHandlers []string `protobuf:"bytes,23,rep,name=output_metric_handlers,json=outputMetricHandlers" json:"output_metric_handlers"` // EnvVars is the list of environment variables to set for the check's // execution environment. EnvVars []string `protobuf:"bytes,24,rep,name=env_vars,json=envVars" json:"env_vars"` // Metadata contains the name, namespace, labels and annotations of the // check ObjectMeta `protobuf:"bytes,26,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // MaxOutputSize is the maximum size in bytes that will be stored for check // output. If check output is larger than MaxOutputSize, it will be // truncated when stored. Filters, mutators, and handlers will still have // access to the full check output at the time the event occurs. MaxOutputSize int64 `protobuf:"varint,27,opt,name=max_output_size,json=maxOutputSize,proto3" json:"max_output_size,omitempty"` // DiscardOutput causes agents to discard check output. No check output is // written to the backend, but metrics extraction is still performed. DiscardOutput bool `protobuf:"varint,28,opt,name=discard_output,json=discardOutput,proto3" json:"discard_output,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CheckConfig is the specification of a check.
func FixtureCheckConfig ¶
func FixtureCheckConfig(id string) *CheckConfig
FixtureCheckConfig returns a fixture for a CheckConfig object.
func NewCheckConfig ¶
func NewCheckConfig(meta ObjectMeta) *CheckConfig
NewCheckConfig creates a new CheckConfig.
func NewCheckConfigFromFace ¶
func NewCheckConfigFromFace(that CheckConfigFace) *CheckConfig
func NewPopulatedCheckConfig ¶
func NewPopulatedCheckConfig(r randyCheck, easy bool) *CheckConfig
func (*CheckConfig) Descriptor ¶
func (*CheckConfig) Descriptor() ([]byte, []int)
func (*CheckConfig) Equal ¶
func (this *CheckConfig) Equal(that interface{}) bool
func (*CheckConfig) GetCheckHooks ¶
func (this *CheckConfig) GetCheckHooks() []HookList
func (*CheckConfig) GetCommand ¶
func (this *CheckConfig) GetCommand() string
func (*CheckConfig) GetCron ¶
func (this *CheckConfig) GetCron() string
func (*CheckConfig) GetDiscardOutput ¶
func (this *CheckConfig) GetDiscardOutput() bool
func (*CheckConfig) GetEnvVars ¶
func (this *CheckConfig) GetEnvVars() []string
func (*CheckConfig) GetExtendedAttributes ¶
func (this *CheckConfig) GetExtendedAttributes() []byte
func (*CheckConfig) GetHandlers ¶
func (this *CheckConfig) GetHandlers() []string
func (*CheckConfig) GetHighFlapThreshold ¶
func (this *CheckConfig) GetHighFlapThreshold() uint32
func (*CheckConfig) GetInterval ¶
func (this *CheckConfig) GetInterval() uint32
func (*CheckConfig) GetLowFlapThreshold ¶
func (this *CheckConfig) GetLowFlapThreshold() uint32
func (*CheckConfig) GetMaxOutputSize ¶
func (this *CheckConfig) GetMaxOutputSize() int64
func (*CheckConfig) GetObjectMeta ¶
func (this *CheckConfig) GetObjectMeta() ObjectMeta
func (*CheckConfig) GetOutputMetricFormat ¶
func (this *CheckConfig) GetOutputMetricFormat() string
func (*CheckConfig) GetOutputMetricHandlers ¶
func (this *CheckConfig) GetOutputMetricHandlers() []string
func (*CheckConfig) GetProxyEntityName ¶
func (this *CheckConfig) GetProxyEntityName() string
func (*CheckConfig) GetProxyRequests ¶
func (this *CheckConfig) GetProxyRequests() *ProxyRequests
func (*CheckConfig) GetPublish ¶
func (this *CheckConfig) GetPublish() bool
func (*CheckConfig) GetRoundRobin ¶
func (this *CheckConfig) GetRoundRobin() bool
func (*CheckConfig) GetRuntimeAssets ¶
func (this *CheckConfig) GetRuntimeAssets() []string
func (*CheckConfig) GetStdin ¶
func (this *CheckConfig) GetStdin() bool
func (*CheckConfig) GetSubdue ¶
func (this *CheckConfig) GetSubdue() *TimeWindowWhen
func (*CheckConfig) GetSubscriptions ¶
func (this *CheckConfig) GetSubscriptions() []string
func (*CheckConfig) GetTimeout ¶
func (this *CheckConfig) GetTimeout() uint32
func (*CheckConfig) GetTtl ¶
func (this *CheckConfig) GetTtl() int64
func (*CheckConfig) IsSubdued ¶
func (c *CheckConfig) IsSubdued() bool
IsSubdued returns true if the check is subdued at the current time. It returns false otherwise.
func (*CheckConfig) Marshal ¶
func (m *CheckConfig) Marshal() (dAtA []byte, err error)
func (*CheckConfig) MarshalJSON ¶
func (c *CheckConfig) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaler interface.
func (*CheckConfig) Proto ¶
func (this *CheckConfig) Proto() github_com_golang_protobuf_proto.Message
func (*CheckConfig) ProtoMessage ¶
func (*CheckConfig) ProtoMessage()
func (*CheckConfig) Reset ¶
func (m *CheckConfig) Reset()
func (*CheckConfig) SetNamespace ¶
func (c *CheckConfig) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*CheckConfig) Size ¶
func (m *CheckConfig) Size() (n int)
func (*CheckConfig) StorePrefix ¶
func (c *CheckConfig) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*CheckConfig) String ¶
func (m *CheckConfig) String() string
func (*CheckConfig) TestProto ¶
func (this *CheckConfig) TestProto() github_com_golang_protobuf_proto.Message
func (*CheckConfig) URIPath ¶
func (c *CheckConfig) URIPath() string
URIPath returns the path component of a CheckConfig URI.
func (*CheckConfig) Unmarshal ¶
func (m *CheckConfig) Unmarshal(dAtA []byte) error
func (*CheckConfig) Validate ¶
func (c *CheckConfig) Validate() error
Validate returns an error if the check does not pass validation tests.
func (*CheckConfig) XXX_DiscardUnknown ¶
func (m *CheckConfig) XXX_DiscardUnknown()
func (*CheckConfig) XXX_Marshal ¶
func (m *CheckConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckConfig) XXX_Merge ¶
func (dst *CheckConfig) XXX_Merge(src proto.Message)
func (*CheckConfig) XXX_Size ¶
func (m *CheckConfig) XXX_Size() int
func (*CheckConfig) XXX_Unmarshal ¶
func (m *CheckConfig) XXX_Unmarshal(b []byte) error
type CheckConfigFace ¶
type CheckConfigFace interface { Proto() github_com_golang_protobuf_proto.Message GetCommand() string GetHandlers() []string GetHighFlapThreshold() uint32 GetInterval() uint32 GetLowFlapThreshold() uint32 GetPublish() bool GetRuntimeAssets() []string GetSubscriptions() []string GetExtendedAttributes() []byte GetProxyEntityName() string GetCheckHooks() []HookList GetStdin() bool GetSubdue() *TimeWindowWhen GetCron() string GetTtl() int64 GetTimeout() uint32 GetProxyRequests() *ProxyRequests GetRoundRobin() bool GetOutputMetricFormat() string GetOutputMetricHandlers() []string GetEnvVars() []string GetObjectMeta() ObjectMeta GetMaxOutputSize() int64 GetDiscardOutput() bool }
type CheckFace ¶
type CheckFace interface { Proto() github_com_golang_protobuf_proto.Message GetCommand() string GetHandlers() []string GetHighFlapThreshold() uint32 GetInterval() uint32 GetLowFlapThreshold() uint32 GetPublish() bool GetRuntimeAssets() []string GetSubscriptions() []string GetProxyEntityName() string GetCheckHooks() []HookList GetStdin() bool GetSubdue() *TimeWindowWhen GetCron() string GetTtl() int64 GetTimeout() uint32 GetProxyRequests() *ProxyRequests GetRoundRobin() bool GetDuration() float64 GetExecuted() int64 GetHistory() []CheckHistory GetIssued() int64 GetOutput() string GetState() string GetStatus() uint32 GetTotalStateChange() uint32 GetLastOK() int64 GetOccurrences() int64 GetOccurrencesWatermark() int64 GetSilenced() []string GetHooks() []*Hook GetOutputMetricFormat() string GetOutputMetricHandlers() []string GetEnvVars() []string GetObjectMeta() ObjectMeta GetMaxOutputSize() int64 GetDiscardOutput() bool GetExtendedAttributes() []byte }
type CheckHistory ¶
type CheckHistory struct { // Status is the exit status code produced by the check. Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status"` // Executed describes the time in which the check request was executed Executed int64 `protobuf:"varint,2,opt,name=executed,proto3" json:"executed"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CheckHistory is a record of a check execution and its status
func NewPopulatedCheckHistory ¶
func NewPopulatedCheckHistory(r randyCheck, easy bool) *CheckHistory
func (*CheckHistory) Descriptor ¶
func (*CheckHistory) Descriptor() ([]byte, []int)
func (*CheckHistory) Equal ¶
func (this *CheckHistory) Equal(that interface{}) bool
func (*CheckHistory) GetExecuted ¶
func (m *CheckHistory) GetExecuted() int64
func (*CheckHistory) GetStatus ¶
func (m *CheckHistory) GetStatus() uint32
func (*CheckHistory) Marshal ¶
func (m *CheckHistory) Marshal() (dAtA []byte, err error)
func (*CheckHistory) ProtoMessage ¶
func (*CheckHistory) ProtoMessage()
func (*CheckHistory) Reset ¶
func (m *CheckHistory) Reset()
func (*CheckHistory) Size ¶
func (m *CheckHistory) Size() (n int)
func (*CheckHistory) String ¶
func (m *CheckHistory) String() string
func (*CheckHistory) Unmarshal ¶
func (m *CheckHistory) Unmarshal(dAtA []byte) error
func (*CheckHistory) XXX_DiscardUnknown ¶
func (m *CheckHistory) XXX_DiscardUnknown()
func (*CheckHistory) XXX_Marshal ¶
func (m *CheckHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckHistory) XXX_Merge ¶
func (dst *CheckHistory) XXX_Merge(src proto.Message)
func (*CheckHistory) XXX_Size ¶
func (m *CheckHistory) XXX_Size() int
func (*CheckHistory) XXX_Unmarshal ¶
func (m *CheckHistory) XXX_Unmarshal(b []byte) error
type CheckRequest ¶
type CheckRequest struct { // Config is the specification of a check. Config *CheckConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"` // Assets are a list of assets required to execute check. Assets []Asset `protobuf:"bytes,2,rep,name=assets" json:"assets"` // Hooks are a list of hooks to be executed after a check. Hooks []HookConfig `protobuf:"bytes,3,rep,name=hooks" json:"hooks"` // Issued describes the time in which the check request was issued Issued int64 `protobuf:"varint,4,opt,name=Issued,proto3" json:"issued"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A CheckRequest represents a request to execute a check
func FixtureCheckRequest ¶
func FixtureCheckRequest(id string) *CheckRequest
FixtureCheckRequest returns a fixture for a CheckRequest object.
func NewPopulatedCheckRequest ¶
func NewPopulatedCheckRequest(r randyCheck, easy bool) *CheckRequest
func (*CheckRequest) Descriptor ¶
func (*CheckRequest) Descriptor() ([]byte, []int)
func (*CheckRequest) Equal ¶
func (this *CheckRequest) Equal(that interface{}) bool
func (*CheckRequest) GetAssets ¶
func (m *CheckRequest) GetAssets() []Asset
func (*CheckRequest) GetConfig ¶
func (m *CheckRequest) GetConfig() *CheckConfig
func (*CheckRequest) GetHooks ¶
func (m *CheckRequest) GetHooks() []HookConfig
func (*CheckRequest) GetIssued ¶
func (m *CheckRequest) GetIssued() int64
func (*CheckRequest) Marshal ¶
func (m *CheckRequest) Marshal() (dAtA []byte, err error)
func (*CheckRequest) ProtoMessage ¶
func (*CheckRequest) ProtoMessage()
func (*CheckRequest) Reset ¶
func (m *CheckRequest) Reset()
func (*CheckRequest) Size ¶
func (m *CheckRequest) Size() (n int)
func (*CheckRequest) String ¶
func (m *CheckRequest) String() string
func (*CheckRequest) Unmarshal ¶
func (m *CheckRequest) Unmarshal(dAtA []byte) error
func (*CheckRequest) XXX_DiscardUnknown ¶
func (m *CheckRequest) XXX_DiscardUnknown()
func (*CheckRequest) XXX_Marshal ¶
func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckRequest) XXX_Merge ¶
func (dst *CheckRequest) XXX_Merge(src proto.Message)
func (*CheckRequest) XXX_Size ¶
func (m *CheckRequest) XXX_Size() int
func (*CheckRequest) XXX_Unmarshal ¶
func (m *CheckRequest) XXX_Unmarshal(b []byte) error
type Claims ¶
type Claims struct { jwt.StandardClaims // Custom claims Groups []string `json:"groups"` Provider AuthProviderClaims `json:"provider"` }
Claims represents the JWT claims
func FixtureClaims ¶
FixtureClaims returns a testing fixture for a JWT claims
type ClusterHealth ¶
type ClusterHealth struct { // MemberID is the etcd cluster member's ID. MemberID uint64 // Name is the cluster member's name. Name string // Err holds the string representation of any errors encountered while checking the member's health. Err string // Healthy describes the health of the cluster member. Healthy bool }
ClusterHealth holds cluster member status info.
type ClusterRole ¶
type ClusterRole struct { Rules []Rule `protobuf:"bytes,1,rep,name=rules" json:"rules"` // Metadata contains name, namespace, labels and annotations ObjectMeta `protobuf:"bytes,3,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ClusterRole applies to all namespaces within a cluster.
func FixtureClusterRole ¶
func FixtureClusterRole(name string) *ClusterRole
FixtureClusterRole returns a partial role
func NewClusterRoleFromFace ¶
func NewClusterRoleFromFace(that ClusterRoleFace) *ClusterRole
func NewPopulatedClusterRole ¶
func NewPopulatedClusterRole(r randyRbac, easy bool) *ClusterRole
func (*ClusterRole) Descriptor ¶
func (*ClusterRole) Descriptor() ([]byte, []int)
func (*ClusterRole) Equal ¶
func (this *ClusterRole) Equal(that interface{}) bool
func (*ClusterRole) GetObjectMeta ¶
func (this *ClusterRole) GetObjectMeta() ObjectMeta
func (*ClusterRole) GetRules ¶
func (this *ClusterRole) GetRules() []Rule
func (*ClusterRole) Marshal ¶
func (m *ClusterRole) Marshal() (dAtA []byte, err error)
func (*ClusterRole) Proto ¶
func (this *ClusterRole) Proto() github_com_golang_protobuf_proto.Message
func (*ClusterRole) ProtoMessage ¶
func (*ClusterRole) ProtoMessage()
func (*ClusterRole) Reset ¶
func (m *ClusterRole) Reset()
func (*ClusterRole) SetNamespace ¶
func (r *ClusterRole) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*ClusterRole) Size ¶
func (m *ClusterRole) Size() (n int)
func (*ClusterRole) StorePrefix ¶
func (r *ClusterRole) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*ClusterRole) String ¶
func (m *ClusterRole) String() string
func (*ClusterRole) TestProto ¶
func (this *ClusterRole) TestProto() github_com_golang_protobuf_proto.Message
func (*ClusterRole) URIPath ¶
func (r *ClusterRole) URIPath() string
URIPath returns the path component of a cluster role URI.
func (*ClusterRole) Unmarshal ¶
func (m *ClusterRole) Unmarshal(dAtA []byte) error
func (*ClusterRole) XXX_DiscardUnknown ¶
func (m *ClusterRole) XXX_DiscardUnknown()
func (*ClusterRole) XXX_Marshal ¶
func (m *ClusterRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterRole) XXX_Merge ¶
func (dst *ClusterRole) XXX_Merge(src proto.Message)
func (*ClusterRole) XXX_Size ¶
func (m *ClusterRole) XXX_Size() int
func (*ClusterRole) XXX_Unmarshal ¶
func (m *ClusterRole) XXX_Unmarshal(b []byte) error
type ClusterRoleBinding ¶
type ClusterRoleBinding struct { // Subjects holds references to the objects the ClusterRole applies to Subjects []Subject `protobuf:"bytes,1,rep,name=subjects" json:"subjects"` // RoleRef references a ClusterRole in the current namespace RoleRef RoleRef `protobuf:"bytes,2,opt,name=role_ref,json=roleRef" json:"role_ref"` // Metadata contains name, namespace, labels and annotations ObjectMeta `protobuf:"bytes,4,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ClusterRoleBinding grants the permissions defined in a ClusterRole referenced to a user or a set of users
func FixtureClusterRoleBinding ¶
func FixtureClusterRoleBinding(name string) *ClusterRoleBinding
FixtureClusterRoleBinding creates a ClusterRoleBinding for testing
func NewClusterRoleBindingFromFace ¶
func NewClusterRoleBindingFromFace(that ClusterRoleBindingFace) *ClusterRoleBinding
func NewPopulatedClusterRoleBinding ¶
func NewPopulatedClusterRoleBinding(r randyRbac, easy bool) *ClusterRoleBinding
func (*ClusterRoleBinding) Descriptor ¶
func (*ClusterRoleBinding) Descriptor() ([]byte, []int)
func (*ClusterRoleBinding) Equal ¶
func (this *ClusterRoleBinding) Equal(that interface{}) bool
func (*ClusterRoleBinding) GetObjectMeta ¶
func (this *ClusterRoleBinding) GetObjectMeta() ObjectMeta
func (*ClusterRoleBinding) GetRoleRef ¶
func (this *ClusterRoleBinding) GetRoleRef() RoleRef
func (*ClusterRoleBinding) GetSubjects ¶
func (this *ClusterRoleBinding) GetSubjects() []Subject
func (*ClusterRoleBinding) Marshal ¶
func (m *ClusterRoleBinding) Marshal() (dAtA []byte, err error)
func (*ClusterRoleBinding) MarshalTo ¶
func (m *ClusterRoleBinding) MarshalTo(dAtA []byte) (int, error)
func (*ClusterRoleBinding) Proto ¶
func (this *ClusterRoleBinding) Proto() github_com_golang_protobuf_proto.Message
func (*ClusterRoleBinding) ProtoMessage ¶
func (*ClusterRoleBinding) ProtoMessage()
func (*ClusterRoleBinding) Reset ¶
func (m *ClusterRoleBinding) Reset()
func (*ClusterRoleBinding) SetNamespace ¶
func (b *ClusterRoleBinding) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*ClusterRoleBinding) Size ¶
func (m *ClusterRoleBinding) Size() (n int)
func (*ClusterRoleBinding) StorePrefix ¶
func (b *ClusterRoleBinding) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*ClusterRoleBinding) String ¶
func (m *ClusterRoleBinding) String() string
func (*ClusterRoleBinding) TestProto ¶
func (this *ClusterRoleBinding) TestProto() github_com_golang_protobuf_proto.Message
func (*ClusterRoleBinding) URIPath ¶
func (b *ClusterRoleBinding) URIPath() string
URIPath returns the path component of a cluster role binding URI.
func (*ClusterRoleBinding) Unmarshal ¶
func (m *ClusterRoleBinding) Unmarshal(dAtA []byte) error
func (*ClusterRoleBinding) Validate ¶
func (b *ClusterRoleBinding) Validate() error
Validate a ClusterRoleBinding
func (*ClusterRoleBinding) XXX_DiscardUnknown ¶
func (m *ClusterRoleBinding) XXX_DiscardUnknown()
func (*ClusterRoleBinding) XXX_Marshal ¶
func (m *ClusterRoleBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterRoleBinding) XXX_Merge ¶
func (dst *ClusterRoleBinding) XXX_Merge(src proto.Message)
func (*ClusterRoleBinding) XXX_Size ¶
func (m *ClusterRoleBinding) XXX_Size() int
func (*ClusterRoleBinding) XXX_Unmarshal ¶
func (m *ClusterRoleBinding) XXX_Unmarshal(b []byte) error
type ClusterRoleBindingFace ¶
type ClusterRoleBindingFace interface { Proto() github_com_golang_protobuf_proto.Message GetSubjects() []Subject GetRoleRef() RoleRef GetObjectMeta() ObjectMeta }
type ClusterRoleFace ¶
type ClusterRoleFace interface { Proto() github_com_golang_protobuf_proto.Message GetRules() []Rule GetObjectMeta() ObjectMeta }
type ConstrainedResource ¶
type ConstrainedResource interface {
Validate() error
}
ConstrainedResource defines a resources that has contraints on it's attributes
type Deregistration ¶
type Deregistration struct { Handler string `protobuf:"bytes,1,opt,name=handler,proto3" json:"handler,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deregistration contains configuration for Sensu entity de-registration.
func NewPopulatedDeregistration ¶
func NewPopulatedDeregistration(r randyEntity, easy bool) *Deregistration
func (*Deregistration) Descriptor ¶
func (*Deregistration) Descriptor() ([]byte, []int)
func (*Deregistration) Equal ¶
func (this *Deregistration) Equal(that interface{}) bool
func (*Deregistration) GetHandler ¶
func (m *Deregistration) GetHandler() string
func (*Deregistration) Marshal ¶
func (m *Deregistration) Marshal() (dAtA []byte, err error)
func (*Deregistration) ProtoMessage ¶
func (*Deregistration) ProtoMessage()
func (*Deregistration) Reset ¶
func (m *Deregistration) Reset()
func (*Deregistration) Size ¶
func (m *Deregistration) Size() (n int)
func (*Deregistration) String ¶
func (m *Deregistration) String() string
func (*Deregistration) Unmarshal ¶
func (m *Deregistration) Unmarshal(dAtA []byte) error
func (*Deregistration) XXX_DiscardUnknown ¶
func (m *Deregistration) XXX_DiscardUnknown()
func (*Deregistration) XXX_Marshal ¶
func (m *Deregistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Deregistration) XXX_Merge ¶
func (dst *Deregistration) XXX_Merge(src proto.Message)
func (*Deregistration) XXX_Size ¶
func (m *Deregistration) XXX_Size() int
func (*Deregistration) XXX_Unmarshal ¶
func (m *Deregistration) XXX_Unmarshal(b []byte) error
type Entity ¶
type Entity struct { EntityClass string `protobuf:"bytes,1,opt,name=entity_class,json=entityClass,proto3" json:"entity_class"` System System `protobuf:"bytes,3,opt,name=system" json:"system"` Subscriptions []string `protobuf:"bytes,4,rep,name=subscriptions" json:"subscriptions"` LastSeen int64 `protobuf:"varint,5,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen"` Deregister bool `protobuf:"varint,6,opt,name=deregister,proto3" json:"deregister"` Deregistration Deregistration `protobuf:"bytes,7,opt,name=deregistration" json:"deregistration"` User string `protobuf:"bytes,11,opt,name=user,proto3" json:"user,omitempty"` // ExtendedAttributes store serialized arbitrary JSON-encoded data ExtendedAttributes []byte `protobuf:"bytes,12,opt,name=extended_attributes,json=extendedAttributes,proto3" json:"-"` // Redact contains the fields to redact on the agent Redact []string `protobuf:"bytes,13,rep,name=redact" json:"redact,omitempty"` // Metadata contains the name, namespace, labels and annotations of the entity ObjectMeta `protobuf:"bytes,14,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Entity is the Entity supplying the event. The default Entity for any Event is the running Agent process--if the Event is sent by an Agent.
func FixtureEntity ¶
FixtureEntity returns a testing fixture for an Entity object.
func NewEntityFromFace ¶
func NewEntityFromFace(that EntityFace) *Entity
func NewPopulatedEntity ¶
func (*Entity) Descriptor ¶
func (*Entity) GetDeregister ¶
func (*Entity) GetDeregistration ¶
func (this *Entity) GetDeregistration() Deregistration
func (*Entity) GetEntityClass ¶
func (*Entity) GetExtendedAttributes ¶
func (*Entity) GetLastSeen ¶
func (*Entity) GetObjectMeta ¶
func (this *Entity) GetObjectMeta() ObjectMeta
func (*Entity) GetRedactedEntity ¶
GetRedactedEntity redacts the entity according to the entity's Redact fields. A redacted copy is returned. The copy contains pointers to the original's memory, with different Labels and Annotations.
func (*Entity) GetSubscriptions ¶
func (*Entity) MarshalJSON ¶
MarshalJSON implements the json.Marshaler interface.
func (*Entity) Proto ¶
func (this *Entity) Proto() github_com_golang_protobuf_proto.Message
func (*Entity) ProtoMessage ¶
func (*Entity) ProtoMessage()
func (*Entity) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Entity) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Entity) TestProto ¶
func (this *Entity) TestProto() github_com_golang_protobuf_proto.Message
func (*Entity) XXX_DiscardUnknown ¶
func (m *Entity) XXX_DiscardUnknown()
func (*Entity) XXX_Marshal ¶
func (*Entity) XXX_Unmarshal ¶
type EntityFace ¶
type EntityFace interface { Proto() github_com_golang_protobuf_proto.Message GetEntityClass() string GetSystem() System GetSubscriptions() []string GetLastSeen() int64 GetDeregister() bool GetDeregistration() Deregistration GetUser() string GetExtendedAttributes() []byte GetRedact() []string GetObjectMeta() ObjectMeta }
type Event ¶
type Event struct { // Timestamp is the time in seconds since the Epoch. Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Entity describes the entity in which the event occurred. Entity *Entity `protobuf:"bytes,2,opt,name=entity" json:"entity,omitempty"` // Check describes the result of a check; if event is associated to check execution. Check *Check `protobuf:"bytes,3,opt,name=check" json:"check,omitempty"` // Metrics are zero or more Sensu metrics Metrics *Metrics `protobuf:"bytes,4,opt,name=metrics" json:"metrics,omitempty"` // Metadata contains name, namespace, labels and annotations ObjectMeta `protobuf:"bytes,5,opt,name=metadata,embedded=metadata" json:"metadata"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An Event is the encapsulating type sent across the Sensu websocket transport.
func FixtureEvent ¶
FixtureEvent returns a testing fixture for an Event object.
func NewEventFromFace ¶
func NewPopulatedEvent ¶
func (*Event) Descriptor ¶
func (*Event) GetMetrics ¶
func (*Event) GetObjectMeta ¶
func (this *Event) GetObjectMeta() ObjectMeta
func (*Event) GetTimestamp ¶
func (*Event) HasMetrics ¶
HasMetrics determines if an event has metric data.
func (*Event) IsIncident ¶
IsIncident determines if an event indicates an incident.
func (*Event) IsResolution ¶
IsResolution returns true if an event has just transitionned from an incident
func (*Event) IsSilenced ¶
IsSilenced determines if an event has any silenced entries
func (*Event) IsSilencedBy ¶
IsSilencedBy returns true if given silence will silence the event.
func (*Event) Proto ¶
func (this *Event) Proto() github_com_golang_protobuf_proto.Message
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Event) SilencedBy ¶
SilencedBy returns the subset of given silences, that silence the event.
func (*Event) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Event) SynthesizeExtras ¶
SynthesizeExtras implements dynamic.SynthesizeExtras
func (*Event) TestProto ¶
func (this *Event) TestProto() github_com_golang_protobuf_proto.Message
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventFace ¶
type EventFace interface { Proto() github_com_golang_protobuf_proto.Message GetTimestamp() int64 GetEntity() *Entity GetCheck() *Check GetMetrics() *Metrics GetObjectMeta() ObjectMeta }
type EventFilter ¶
type EventFilter struct { // Metadata contains the name, namespace, labels and annotations of the filter ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // Action specifies to allow/deny events to continue through the pipeline Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // Expressions is an array of boolean expressions that are &&'d together // to determine if the event matches this filter. Expressions []string `protobuf:"bytes,3,rep,name=expressions" json:"expressions"` // When indicates a TimeWindowWhen that a filter uses to filter by days & times When *TimeWindowWhen `protobuf:"bytes,6,opt,name=when" json:"when,omitempty"` // Runtime assets are Sensu assets that contain javascript libraries. They // are evaluated within the execution context. RuntimeAssets []string `protobuf:"bytes,8,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EventFilter is a filter specification.
func FixtureDenyEventFilter ¶
func FixtureDenyEventFilter(name string) *EventFilter
FixtureDenyEventFilter returns a Filter fixture for testing.
func FixtureEventFilter ¶
func FixtureEventFilter(name string) *EventFilter
FixtureEventFilter returns a Filter fixture for testing.
func NewEventFilter ¶
func NewEventFilter(meta ObjectMeta) *EventFilter
NewEventFilter creates a new EventFilter.
func NewEventFilterFromFace ¶
func NewEventFilterFromFace(that EventFilterFace) *EventFilter
func NewPopulatedEventFilter ¶
func NewPopulatedEventFilter(r randyFilter, easy bool) *EventFilter
func (*EventFilter) Descriptor ¶
func (*EventFilter) Descriptor() ([]byte, []int)
func (*EventFilter) Equal ¶
func (this *EventFilter) Equal(that interface{}) bool
func (*EventFilter) GetAction ¶
func (this *EventFilter) GetAction() string
func (*EventFilter) GetExpressions ¶
func (this *EventFilter) GetExpressions() []string
func (*EventFilter) GetObjectMeta ¶
func (this *EventFilter) GetObjectMeta() ObjectMeta
func (*EventFilter) GetRuntimeAssets ¶
func (this *EventFilter) GetRuntimeAssets() []string
func (*EventFilter) GetWhen ¶
func (this *EventFilter) GetWhen() *TimeWindowWhen
func (*EventFilter) Marshal ¶
func (m *EventFilter) Marshal() (dAtA []byte, err error)
func (*EventFilter) Proto ¶
func (this *EventFilter) Proto() github_com_golang_protobuf_proto.Message
func (*EventFilter) ProtoMessage ¶
func (*EventFilter) ProtoMessage()
func (*EventFilter) Reset ¶
func (m *EventFilter) Reset()
func (*EventFilter) SetNamespace ¶
func (f *EventFilter) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*EventFilter) Size ¶
func (m *EventFilter) Size() (n int)
func (*EventFilter) StorePrefix ¶
func (f *EventFilter) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*EventFilter) String ¶
func (m *EventFilter) String() string
func (*EventFilter) TestProto ¶
func (this *EventFilter) TestProto() github_com_golang_protobuf_proto.Message
func (*EventFilter) URIPath ¶
func (f *EventFilter) URIPath() string
URIPath returns the path component of an event filter URI.
func (*EventFilter) Unmarshal ¶
func (m *EventFilter) Unmarshal(dAtA []byte) error
func (*EventFilter) Update ¶
func (f *EventFilter) Update(from *EventFilter, fields ...string) error
Update updates e with selected fields. Returns non-nil error if any of the selected fields are unsupported.
func (*EventFilter) Validate ¶
func (f *EventFilter) Validate() error
Validate returns an error if the filter does not pass validation tests.
func (*EventFilter) XXX_DiscardUnknown ¶
func (m *EventFilter) XXX_DiscardUnknown()
func (*EventFilter) XXX_Marshal ¶
func (m *EventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventFilter) XXX_Merge ¶
func (dst *EventFilter) XXX_Merge(src proto.Message)
func (*EventFilter) XXX_Size ¶
func (m *EventFilter) XXX_Size() int
func (*EventFilter) XXX_Unmarshal ¶
func (m *EventFilter) XXX_Unmarshal(b []byte) error
type EventFilterFace ¶
type EventFilterFace interface { Proto() github_com_golang_protobuf_proto.Message GetObjectMeta() ObjectMeta GetAction() string GetExpressions() []string GetWhen() *TimeWindowWhen GetRuntimeAssets() []string }
type Extension ¶
type Extension struct { // Metadata contains the name, namespace, labels and annotations of the extension ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // URL is the URL of the gRPC service that implements the extension. URL string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Extension is a registered sensu extension.
func FixtureExtension ¶
FixtureExtension given a name returns a valid extension for use in tests
func NewExtension ¶
func NewExtension(meta ObjectMeta) *Extension
NewExtension intializes an extension with the given object meta
func NewExtensionFromFace ¶
func NewExtensionFromFace(that ExtensionFace) *Extension
func NewPopulatedExtension ¶
func (*Extension) Descriptor ¶
func (*Extension) GetObjectMeta ¶
func (this *Extension) GetObjectMeta() ObjectMeta
func (*Extension) Proto ¶
func (this *Extension) Proto() github_com_golang_protobuf_proto.Message
func (*Extension) ProtoMessage ¶
func (*Extension) ProtoMessage()
func (*Extension) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Extension) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Extension) TestProto ¶
func (this *Extension) TestProto() github_com_golang_protobuf_proto.Message
func (*Extension) XXX_DiscardUnknown ¶
func (m *Extension) XXX_DiscardUnknown()
func (*Extension) XXX_Marshal ¶
func (*Extension) XXX_Unmarshal ¶
type ExtensionFace ¶
type ExtensionFace interface { Proto() github_com_golang_protobuf_proto.Message GetObjectMeta() ObjectMeta GetURL() string }
type Handler ¶
type Handler struct { // Metadata contains the name, namespace, labels and annotations of the handler ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // Type is the handler type, i.e. pipe. Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Mutator is the handler event data mutator. Mutator string `protobuf:"bytes,3,opt,name=mutator,proto3" json:"mutator,omitempty"` // Command is the command to be executed for a pipe handler. Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` // Timeout is the handler timeout in seconds. Timeout uint32 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout"` // Socket contains configuration for a TCP or UDP handler. Socket *HandlerSocket `protobuf:"bytes,6,opt,name=socket" json:"socket,omitempty"` // Handlers is a list of handlers for a handler set. Handlers []string `protobuf:"bytes,7,rep,name=handlers" json:"handlers"` // Filters is a list of filters name to evaluate before executing this handler Filters []string `protobuf:"bytes,8,rep,name=filters" json:"filters"` // EnvVars is a list of environment variables to use with command execution EnvVars []string `protobuf:"bytes,9,rep,name=env_vars,json=envVars" json:"env_vars"` // RuntimeAssets are a list of assets required to execute a handler. RuntimeAssets []string `protobuf:"bytes,13,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A Handler is a handler specification.
func FakeHandlerCommand ¶
FakeHandlerCommand takes a command and (optionally) command args and will execute the TestHelperHandlerProcess test within the package FakeHandlerCommand is called from.
func FixtureHandler ¶
FixtureHandler returns a Handler fixture for testing.
func FixtureSetHandler ¶
FixtureSetHandler returns a Handler fixture for testing.
func FixtureSocketHandler ¶
FixtureSocketHandler returns a Handler fixture for testing.
func NewHandlerFromFace ¶
func NewHandlerFromFace(that HandlerFace) *Handler
func NewPopulatedHandler ¶
func (*Handler) Descriptor ¶
func (*Handler) GetCommand ¶
func (*Handler) GetEnvVars ¶
func (*Handler) GetFilters ¶
func (*Handler) GetHandlers ¶
func (*Handler) GetMutator ¶
func (*Handler) GetObjectMeta ¶
func (this *Handler) GetObjectMeta() ObjectMeta
func (*Handler) GetRuntimeAssets ¶
func (*Handler) GetSocket ¶
func (this *Handler) GetSocket() *HandlerSocket
func (*Handler) GetTimeout ¶
func (*Handler) Proto ¶
func (this *Handler) Proto() github_com_golang_protobuf_proto.Message
func (*Handler) ProtoMessage ¶
func (*Handler) ProtoMessage()
func (*Handler) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Handler) StorePrefix ¶
StorePrefix returns the path prefix to this resource in the store
func (*Handler) TestProto ¶
func (this *Handler) TestProto() github_com_golang_protobuf_proto.Message
func (*Handler) XXX_DiscardUnknown ¶
func (m *Handler) XXX_DiscardUnknown()
func (*Handler) XXX_Marshal ¶
func (*Handler) XXX_Unmarshal ¶
type HandlerFace ¶
type HandlerFace interface { Proto() github_com_golang_protobuf_proto.Message GetObjectMeta() ObjectMeta GetType() string GetMutator() string GetCommand() string GetTimeout() uint32 GetSocket() *HandlerSocket GetHandlers() []string GetFilters() []string GetEnvVars() []string GetRuntimeAssets() []string }
type HandlerSocket ¶
type HandlerSocket struct { // Host is the socket peer address. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Port is the socket peer port. Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
HandlerSocket contains configuration for a TCP or UDP handler.
func NewPopulatedHandlerSocket ¶
func NewPopulatedHandlerSocket(r randyHandler, easy bool) *HandlerSocket
func (*HandlerSocket) Descriptor ¶
func (*HandlerSocket) Descriptor() ([]byte, []int)
func (*HandlerSocket) Equal ¶
func (this *HandlerSocket) Equal(that interface{}) bool
func (*HandlerSocket) GetHost ¶
func (m *HandlerSocket) GetHost() string
func (*HandlerSocket) GetPort ¶
func (m *HandlerSocket) GetPort() uint32
func (*HandlerSocket) Marshal ¶
func (m *HandlerSocket) Marshal() (dAtA []byte, err error)
func (*HandlerSocket) ProtoMessage ¶
func (*HandlerSocket) ProtoMessage()
func (*HandlerSocket) Reset ¶
func (m *HandlerSocket) Reset()
func (*HandlerSocket) Size ¶
func (m *HandlerSocket) Size() (n int)
func (*HandlerSocket) String ¶
func (m *HandlerSocket) String() string
func (*HandlerSocket) Unmarshal ¶
func (m *HandlerSocket) Unmarshal(dAtA []byte) error
func (*HandlerSocket) Validate ¶
func (s *HandlerSocket) Validate() error
Validate returns an error if the handler socket does not pass validation tests.
func (*HandlerSocket) XXX_DiscardUnknown ¶
func (m *HandlerSocket) XXX_DiscardUnknown()
func (*HandlerSocket) XXX_Marshal ¶
func (m *HandlerSocket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandlerSocket) XXX_Merge ¶
func (dst *HandlerSocket) XXX_Merge(src proto.Message)
func (*HandlerSocket) XXX_Size ¶
func (m *HandlerSocket) XXX_Size() int
func (*HandlerSocket) XXX_Unmarshal ¶
func (m *HandlerSocket) XXX_Unmarshal(b []byte) error
type HealthResponse ¶
type HealthResponse struct { // Alarms is the list of active etcd alarms. Alarms []*etcdserverpb.AlarmMember // ClusterHealth is the list of health status for every cluster member. ClusterHealth []*ClusterHealth // Header is the response header for the entire cluster response. Header *etcdserverpb.ResponseHeader }
HealthResponse contains cluster health and cluster alarms.
func FixtureHealthResponse ¶
func FixtureHealthResponse(healthy bool) *HealthResponse
FixtureHealthResponse returns a HealthResponse fixture for testing.
type Hook ¶
type Hook struct { // Config is the specification of a hook HookConfig `protobuf:"bytes,1,opt,name=config,embedded=config" json:""` // Duration of execution Duration float64 `protobuf:"fixed64,2,opt,name=duration,proto3" json:"duration,omitempty"` // Executed describes the time in which the hook request was executed Executed int64 `protobuf:"varint,3,opt,name=executed,proto3" json:"executed"` // Issued describes the time in which the hook request was issued Issued int64 `protobuf:"varint,4,opt,name=issued,proto3" json:"issued"` // Output from the execution of Command Output string `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"` // Status is the exit status code produced by the hook Status int32 `protobuf:"varint,6,opt,name=status,proto3" json:"status"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A Hook is a hook specification and optionally the results of the hook's execution.
func FixtureHook ¶
FixtureHook returns a fixture for a Hook object.
func NewPopulatedHook ¶
func (*Hook) Descriptor ¶
func (*Hook) GetDuration ¶
func (*Hook) GetExecuted ¶
func (*Hook) ProtoMessage ¶
func (*Hook) ProtoMessage()
func (*Hook) SetNamespace ¶
SetNamespace sets the namespace of the resource.
func (*Hook) XXX_DiscardUnknown ¶
func (m *Hook) XXX_DiscardUnknown()
func (*Hook) XXX_Unmarshal ¶
type HookConfig ¶
type HookConfig struct { // Metadata contains the name, namespace, labels and annotations of the hook ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` // Command is the command to be executed Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` // Timeout is the timeout, in seconds, at which the hook has to run Timeout uint32 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout"` // Stdin indicates if hook requests have stdin enabled Stdin bool `protobuf:"varint,4,opt,name=stdin,proto3" json:"stdin"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
HookConfig is the specification of a hook
func FixtureHookConfig ¶
func FixtureHookConfig(name string) *HookConfig
FixtureHookConfig returns a fixture for a HookConfig object.
func NewHookConfigFromFace ¶
func NewHookConfigFromFace(that HookConfigFace) *HookConfig
func NewPopulatedHookConfig ¶
func NewPopulatedHookConfig(r randyHook, easy bool) *HookConfig
func (*HookConfig) Descriptor ¶
func (*HookConfig) Descriptor() ([]byte, []int)
func (*HookConfig) Equal ¶
func (this *HookConfig) Equal(that interface{}) bool
func (*HookConfig) GetCommand ¶
func (this *HookConfig) GetCommand() string
func (*HookConfig) GetObjectMeta ¶
func (this *HookConfig) GetObjectMeta() ObjectMeta
func (*HookConfig) GetStdin ¶
func (this *HookConfig) GetStdin() bool
func (*HookConfig) GetTimeout ¶
func (this *HookConfig) GetTimeout() uint32
func (*HookConfig) Marshal ¶
func (m *HookConfig) Marshal() (dAtA []byte, err error)
func (*HookConfig) Proto ¶
func (this *HookConfig) Proto() github_com_golang_protobuf_proto.Message
func (*HookConfig) ProtoMessage ¶
func (*HookConfig) ProtoMessage()
func (*HookConfig) Reset ¶
func (m *HookConfig) Reset()
func (*HookConfig) SetNamespace ¶
func (c *HookConfig) SetNamespace(namespace string)
SetNamespace sets the namespace of the resource.
func (*HookConfig) Size ¶
func (m *HookConfig) Size() (n int)
func (*HookConfig) StorePrefix ¶
func (c *HookConfig) StorePrefix() string
StorePrefix returns the path prefix to this resource in the store
func (*HookConfig) String ¶
func (m *HookConfig) String() string
func (*HookConfig) TestProto ¶
func (this *HookConfig) TestProto() github_com_golang_protobuf_proto.Message
func (*HookConfig) URIPath ¶
func (c *HookConfig) URIPath() string
URIPath returns the path component of a hook URI.
func (*HookConfig) Unmarshal ¶
func (m *HookConfig) Unmarshal(dAtA []byte) error
func (*HookConfig) Validate ¶
func (c *HookConfig) Validate() error
Validate returns an error if the hook does not pass validation tests.
func (*HookConfig) XXX_DiscardUnknown ¶
func (m *HookConfig) XXX_DiscardUnknown()
func (*HookConfig) XXX_Marshal ¶
func (m *HookConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HookConfig) XXX_Merge ¶
func (dst *HookConfig) XXX_Merge(src proto.Message)
func (*HookConfig) XXX_Size ¶
func (m *HookConfig) XXX_Size() int
func (*HookConfig) XXX_Unmarshal ¶
func (m *HookConfig) XXX_Unmarshal(b []byte) error
type HookConfigFace ¶
type HookConfigFace interface { Proto() github_com_golang_protobuf_proto.Message GetObjectMeta() ObjectMeta GetCommand() string GetTimeout() uint32 GetStdin() bool }
type HookList ¶
type HookList struct { // Hooks is the list of hooks for the check hook Hooks []string `protobuf:"bytes,1,rep,name=hooks" json:"hooks"` // Type indicates the type or response code for the check hook Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func FixtureHookList ¶
FixtureHookList returns a fixture for a HookList object.
func NewPopulatedHookList ¶
func (*HookList) Descriptor ¶
func (*HookList) MarshalJSON ¶
MarshalJSON implements the json.Marshaler interface.
func (*HookList) ProtoMessage ¶
func (*HookList) ProtoMessage()
func (*HookList) UnmarshalJSON ¶
UnmarshalJSON implements the json.Marshaler interface.
func (*HookList) Validate ¶
Validate returns an error if the check hook does not pass validation tests.
func (*HookList) XXX_DiscardUnknown ¶
func (m *HookList) XXX_DiscardUnknown()
func (*HookList) XXX_Marshal ¶
func (*HookList) XXX_Unmarshal ¶
type KeepaliveRecord ¶
type KeepaliveRecord struct { // Metadata contains the name (of the entity), and namespace, labels and annotations of the keepalive record ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"` Time int64 `protobuf:"varint,4,opt,name=time,proto3" json:"time"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A KeepaliveRecord is a tuple of an entity name and the time at which the entity's keepalive will next expire.
func NewKeepaliveRecord ¶
func NewKeepaliveRecord(e *Entity, t int64) *KeepaliveRecord
NewKeepaliveRecord initializes and returns a KeepaliveRecord from an entity and its expiration time.
func NewKeepaliveRecordFromFace ¶
func NewKeepaliveRecordFromFace(that KeepaliveRecordFace) *KeepaliveRecord
func NewPopulatedKeepaliveRecord ¶
func NewPopulatedKeepaliveRecord(r randyKeepalive, easy bool) *KeepaliveRecord
func (*KeepaliveRecord) Descriptor ¶
func (*KeepaliveRecord) Descriptor() ([]byte, []int)
func (*KeepaliveRecord) Equal ¶
func (this *KeepaliveRecord) Equal(that interface{}) bool
func (*KeepaliveRecord) GetObjectMeta ¶
func (this *KeepaliveRecord) GetObjectMeta() ObjectMeta
func (*KeepaliveRecord) GetTime ¶
func (this *KeepaliveRecord) GetTime() int64
func (*KeepaliveRecord) Marshal ¶
func (m *KeepaliveRecord) Marshal() (dAtA []byte, err error)
func (*KeepaliveRecord) Proto ¶
func (this *KeepaliveRecord) Proto() github_com_golang_protobuf_proto.Message
func (*KeepaliveRecord) ProtoMessage ¶
func (*KeepaliveRecord) ProtoMessage()
func (*KeepaliveRecord) Reset ¶
func (m *KeepaliveRecord) Reset()
func (*KeepaliveRecord) Size ¶
func (m *KeepaliveRecord) Size() (n int)
func (*KeepaliveRecord) String ¶
func (m *KeepaliveRecord) String() string
func (*KeepaliveRecord) TestProto ¶
func (this *KeepaliveRecord) TestProto() github_com_golang_protobuf_proto.Message
func (*KeepaliveRecord) Unmarshal ¶
func (m *KeepaliveRecord) Unmarshal(dAtA []byte) error
func (*KeepaliveRecord) XXX_DiscardUnknown ¶
func (m *KeepaliveRecord) XXX_DiscardUnknown()
func (*KeepaliveRecord) XXX_Marshal ¶
func (m *KeepaliveRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepaliveRecord) XXX_Merge ¶
func (dst *KeepaliveRecord) XXX_Merge(src proto.Message)
func (*KeepaliveRecord) XXX_Size ¶
func (m *KeepaliveRecord) XXX_Size() int
func (*KeepaliveRecord) XXX_Unmarshal ¶
func (m *KeepaliveRecord) XXX_Unmarshal(b []byte) error
type KeepaliveRecordFace ¶
type KeepaliveRecordFace interface { Proto() github_com_golang_protobuf_proto.Message GetObjectMeta() ObjectMeta GetTime() int64 }
type MetricPoint ¶
type MetricPoint struct { // The metric point name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The metric point value. Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value"` // The metric point timestamp, time in nanoseconds since the Epoch. Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp"` // Tags is a list of metric tags (dimensions). Tags []*MetricTag `protobuf:"bytes,4,rep,name=tags" json:"tags"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A MetricPoint represents a single measurement.
func FixtureMetricPoint ¶
func FixtureMetricPoint() *MetricPoint
FixtureMetricPoint returns a testing fixture for a Metric Point object.
func NewPopulatedMetricPoint ¶
func NewPopulatedMetricPoint(r randyMetrics, easy bool) *MetricPoint
func (*MetricPoint) Descriptor ¶
func (*MetricPoint) Descriptor() ([]byte, []int)
func (*MetricPoint) Equal ¶
func (this *MetricPoint) Equal(that interface{}) bool
func (*MetricPoint) GetName ¶
func (m *MetricPoint) GetName() string
func (*MetricPoint) GetTags ¶
func (m *MetricPoint) GetTags() []*MetricTag
func (*MetricPoint) GetTimestamp ¶
func (m *MetricPoint) GetTimestamp() int64
func (*MetricPoint) GetValue ¶
func (m *MetricPoint) GetValue() float64
func (*MetricPoint) Marshal ¶
func (m *MetricPoint) Marshal() (dAtA []byte, err error)
func (*MetricPoint) ProtoMessage ¶
func (*MetricPoint) ProtoMessage()
func (*MetricPoint) Reset ¶
func (m *MetricPoint) Reset()
func (*MetricPoint) Size ¶
func (m *MetricPoint) Size() (n int)
func (*MetricPoint) String ¶
func (m *MetricPoint) String() string
func (*MetricPoint) Unmarshal ¶
func (m *MetricPoint) Unmarshal(dAtA []byte) error
func (*MetricPoint) XXX_DiscardUnknown ¶
func (m *MetricPoint) XXX_DiscardUnknown()
func (*MetricPoint) XXX_Marshal ¶
func (m *MetricPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricPoint) XXX_Merge ¶
func (dst *MetricPoint) XXX_Merge(src proto.Message)