v2

package
v5.10.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 25, 2019 License: MIT, MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)
View Source 
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
)
View Source 
const (
	// APIGroupName is the group name for this API
	APIGroupName = "core"

	// APIVersion is the version for this API
	APIVersion = "v2"
)
View Source 
const (
	// CoreEdition represents the Sensu Core Edition (CE)
	// <DEPRECATED>
	CoreEdition = "core"

	// EditionHeader represents the HTTP header containing the edition value
	// <DEPRECATED>
	EditionHeader = "Sensu-Edition"
)
View Source 
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"
)
View Source 
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"
)
View Source 
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
)
View Source 
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"
)
View Source 
const (
	// HooksResource is the name of this resource type
	HooksResource = "hooks"

	// HookRequestType is the message type string for hook request.
	HookRequestType = "hook_request"
)
View Source 
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"
)
View Source 
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"
)
View Source 
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"
)
View Source 
const AgentHandshakeType = "agent_handshake"

AgentHandshakeType is the message type string for an AgentHandshake

View Source 
const (
	// AssetsResource is the name of this resource type
	AssetsResource = "assets"
)
View Source 
const BackendHandshakeType = "backend_handshake"

BackendHandshakeType is the message type string for a BackendHandshake

View Source 
const DefaultKeepaliveTimeout = 120

DefaultKeepaliveTimeout specifies the default keepalive timeout

View Source 
const (
	// ExtensionsResource is the name of this resource type
	ExtensionsResource = "extensions"
)
View Source 
const (
	// MutatorsResource is the name of this resource type
	MutatorsResource = "mutators"
)
View Source 
const PaginationContinueHeader = "Sensu-Continue"

PaginationContinueHeader is the name of the header used by the API to return a potential continue token when paginating.

View Source 
const (
	// SilencedResource is the name of this resource type
	SilencedResource = "silenced"
)
View Source 
const (
	// UsersResource is the name of this resource type
	UsersResource = "users"
)

Variables

View Source 
var (
	ErrInvalidLengthAdhoc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdhoc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthAny = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAny   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	// AssetNameRegexStr used to validate name of asset
	AssetNameRegexStr = `[a-z0-9\/\_\.\-]+`

	// AssetNameRegex used to validate name of asset
	AssetNameRegex = regexp.MustCompile("^" + AssetNameRegexStr + "$")
)
View Source 
var (
	ErrInvalidLengthAsset = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAsset   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthentication   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCheck   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthEntity = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEntity   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExtension = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExtension   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthFilter = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFilter   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHandler = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHandler   = fmt.Errorf("proto: integer overflow")
)
View Source 
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"}
)
View Source 
var (
	ErrInvalidLengthHook = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHook   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthKeepalive = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKeepalive   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMeta   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetrics   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMutator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMutator   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespace   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRbac = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRbac   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSilenced = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSilenced   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTessen = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTessen   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTimeWindow = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTimeWindow   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTls = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTls   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthUser = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUser   = fmt.Errorf("proto: integer overflow")
)
View Source 
var CommonCoreResources = []string{
	"assets",
	"checks",
	"entities",
	"extensions",
	"events",
	"filters",
	"handlers",
	"hooks",
	"mutators",
	"silenced",
}

CommonCoreResources represents the common "core" resources found in a namespace

View Source 
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,
	}
)
View Source 
var DefaultRedactFields = []string{"password", "passwd", "pass", "api_key",
	"api_token", "access_key", "secret_key", "private_key", "secret"}

DefaultRedactFields contains the default fields to redact

View Source 
var (
	// EventFilterAllActions is a list of actions that can be used by filters
	EventFilterAllActions = []string{
		EventFilterActionAllow,
		EventFilterActionDeny,
	}
)
View Source 
var NameRegex = regexp.MustCompile(`\A[\w\.\-]+\z`)

NameRegex is used to validate the name of a resource

View Source 
var OutputMetricFormats = []string{NagiosOutputMetricFormat, GraphiteOutputMetricFormat, OpenTSDBOutputMetricFormat, InfluxDBOutputMetricFormat}

OutputMetricFormats represents all the accepted output_metric_format's a check can have

View Source 
var StrictNameRegex = regexp.MustCompile(`\A[a-z0-9\_\.\-]+\z`)

StrictNameRegex is used to validate names of resources using a strict subset of charset.

View Source 
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)

View Source 
var URLPrefix = path.Join("/api", APIGroupName, APIVersion)

URLPrefix is the URL prefix of this API

Functions

func AssetFields 

func AssetFields(r Resource) map[string]string

AssetFields returns a set of fields that represent that resource

func CheckConfigFields 

func CheckConfigFields(r Resource) map[string]string

CheckConfigFields returns a set of fields that represent that resource

func ClusterRoleBindingFields 

func ClusterRoleBindingFields(r Resource) map[string]string

ClusterRoleBindingFields returns a set of fields that represent that resource

func ClusterRoleFields 

func ClusterRoleFields(r Resource) map[string]string

ClusterRoleFields returns a set of fields that represent that resource

func ContextNamespace 

func ContextNamespace(ctx context.Context) string

ContextNamespace returns the namespace injected in the context

func EntityFields 

func EntityFields(r Resource) map[string]string

EntityFields returns a set of fields that represent that resource

func EnvVarsToMap 

func EnvVarsToMap(vars []string) map[string]string

EnvVarsToMap converts a list of FOO=BAR key-value pairs into a map.

func EventFields 

func EventFields(r Resource) map[string]string

EventFields returns a set of fields that represent that resource

func EventFilterFields 

func EventFilterFields(r Resource) map[string]string

EventFilterFields returns a set of fields that represent that resource

func EventsByLastOk 

func EventsByLastOk(es []*Event) sort.Interface

EventsByLastOk can be used to sort a given collection of events by time it last received an OK status.

func EventsBySeverity 

func EventsBySeverity(es []*Event) sort.Interface

EventsBySeverity can be used to sort a given collection of events by check status and timestamp.

func EventsByTimestamp 

func EventsByTimestamp(es []*Event, asc bool) sort.Interface

EventsByTimestamp can be used to sort a given collection of events by time it occurred.

func ExtensionFields 

func ExtensionFields(r Resource) map[string]string

ExtensionFields returns a set of fields that represent that resource

func GetEntitySubscription 

func GetEntitySubscription(entityName string) string

GetEntitySubscription returns the entity subscription, using the format "entity:entityName"

func HandlerFields 

func HandlerFields(r Resource) map[string]string

HandlerFields returns a set of fields that represent that resource

func HookConfigFields 

func HookConfigFields(r Resource) map[string]string

HookConfigFields returns a set of fields that represent that resource

func LoadCACerts 

func LoadCACerts(path string) (*x509.CertPool, error)

LoadCACerts takes the path to a certificate bundle file in PEM format and try to create a x509.CertPool out of it.

func MutatorFields 

func MutatorFields(r Resource) map[string]string

MutatorFields returns a set of fields that represent that resource

func NamespaceFields 

func NamespaceFields(r Resource) map[string]string

NamespaceFields returns a set of fields that represent that resource

func PageContinueFromContext 

func PageContinueFromContext(ctx context.Context) string

PageContinueFromContext returns the continue token stored in the given context, if any. Returns "" if none is found.

func PageSizeFromContext 

func PageSizeFromContext(ctx context.Context) int

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 

func RoleBindingFields(r Resource) map[string]string

RoleBindingFields returns a set of fields that represent that resource

func RoleFields 

func RoleFields(r Resource) map[string]string

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 

func SilencedFields(r Resource) map[string]string

SilencedFields returns a set of fields that represent that resource

func SilencedName 

func SilencedName(subscription, check string) (string, error)

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 

func SortEntitiesByID(es []*Entity, asc bool) sort.Interface

SortEntitiesByID can be used to sort a given collection of entities by their IDs.

func SortEntitiesByLastSeen 

func SortEntitiesByLastSeen(es []*Entity) sort.Interface

SortEntitiesByLastSeen can be used to sort a given collection of entities by last time each was seen.

func SortEntitiesByPredicate 

func SortEntitiesByPredicate(es []*Entity, fn func(a, b *Entity) bool) sort.Interface

SortEntitiesByPredicate can be used to sort a given collection using a given predicate.

func SortHandlersByName 

func SortHandlersByName(hs []*Handler, asc bool) sort.Interface

SortHandlersByName is used to sort a given collection of handlers by their names.

func SortHandlersByPredicate 

func SortHandlersByPredicate(hs []*Handler, fn cmpHandler) sort.Interface

SortHandlersByPredicate is used to sort a given collection using a given predicate.

func SortSilencedByBegin 

func SortSilencedByBegin(es []*Silenced) sort.Interface

SortSilencedByBegin can be used to sort a given collection by their begin timestamp.

func SortSilencedByName 

func SortSilencedByName(es []*Silenced) sort.Interface

SortSilencedByName can be used to sort a given collection by their names.

func SortSilencedByPredicate 

func SortSilencedByPredicate(es []*Silenced, fn func(a, b *Silenced) bool) sort.Interface

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 

func UserFields(r Resource) map[string]string

UserFields returns a set of fields that represent that resource

func ValidateAssetName 

func ValidateAssetName(name string) error

ValidateAssetName validates that asset's name is valid

func ValidateEnvVars 

func ValidateEnvVars(vars []string) error

ValidateEnvVars ensures that all the environment variables are well-formed. Vars should be of the form FOO=BAR.

func ValidateInterval 

func ValidateInterval(freq uint32) error

ValidateInterval returns an error if the tessen interval is not within the upper and lower bound limits

func ValidateName 

func ValidateName(name string) error

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 

func ValidateNameStrict(name string) error

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 

func ValidateOutputMetricFormat(format string) error

ValidateOutputMetricFormat returns an error if the string is not a valid metric format

func ValidateSubscriptionName 

func ValidateSubscriptionName(name string) error

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) MarshalTo 

func (m *AdhocRequest) MarshalTo(dAtA []byte) (int, 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 NewPopulatedAny(r randyAny, easy bool) *Any

func (*Any) Descriptor 

func (*Any) Descriptor() ([]byte, []int)

func (*Any) Equal 

func (this *Any) Equal(that interface{}) bool

func (*Any) GetTypeUrl 

func (m *Any) GetTypeUrl() string

func (*Any) GetValue 

func (m *Any) GetValue() []byte

func (*Any) Marshal 

func (m *Any) Marshal() (dAtA []byte, err error)

func (*Any) MarshalTo 

func (m *Any) MarshalTo(dAtA []byte) (int, error)

func (*Any) ProtoMessage 

func (*Any) ProtoMessage()

func (*Any) Reset 

func (m *Any) Reset()

func (*Any) Size 

func (m *Any) Size() (n int)

func (*Any) String 

func (m *Any) String() string

func (*Any) Unmarshal 

func (m *Any) Unmarshal(dAtA []byte) error

func (*Any) XXX_DiscardUnknown 

func (m *Any) XXX_DiscardUnknown()

func (*Any) XXX_Marshal 

func (m *Any) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Any) XXX_Merge 

func (dst *Any) XXX_Merge(src proto.Message)

func (*Any) XXX_Size 

func (m *Any) XXX_Size() int

func (*Any) XXX_Unmarshal 

func (m *Any) XXX_Unmarshal(b []byte) error

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 

func FixtureAsset(name string) *Asset

FixtureAsset given a name returns a valid asset for use in tests

func NewAsset 

func NewAsset(meta ObjectMeta) *Asset

NewAsset creates a new Asset.

func NewAssetFromFace 

func NewAssetFromFace(that AssetFace) *Asset

func NewPopulatedAsset 

func NewPopulatedAsset(r randyAsset, easy bool) *Asset

func (*Asset) Descriptor 

func (*Asset) Descriptor() ([]byte, []int)

func (*Asset) Equal 

func (this *Asset) Equal(that interface{}) bool

func (*Asset) Filename 

func (a *Asset) Filename() string

Filename returns the filename of the underlying asset; pulled from the URL

func (*Asset) GetFilters 

func (this *Asset) GetFilters() []string

func (*Asset) GetObjectMeta 

func (this *Asset) GetObjectMeta() ObjectMeta

func (*Asset) GetSha512 

func (this *Asset) GetSha512() string

func (*Asset) GetURL 

func (this *Asset) GetURL() string

func (*Asset) Marshal 

func (m *Asset) Marshal() (dAtA []byte, err error)

func (*Asset) MarshalTo 

func (m *Asset) MarshalTo(dAtA []byte) (int, error)

func (*Asset) Proto 

func (this *Asset) Proto() github_com_golang_protobuf_proto.Message

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) Reset 

func (m *Asset) Reset()

func (*Asset) SetNamespace 

func (a *Asset) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Asset) Size 

func (m *Asset) Size() (n int)

func (*Asset) StorePrefix 

func (a *Asset) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Asset) String 

func (m *Asset) String() string

func (*Asset) TestProto 

func (this *Asset) TestProto() github_com_golang_protobuf_proto.Message

func (*Asset) URIPath 

func (a *Asset) URIPath() string

URIPath returns the path component of an asset URI.

func (*Asset) Unmarshal 

func (m *Asset) Unmarshal(dAtA []byte) error

func (*Asset) Validate 

func (a *Asset) Validate() error

Validate returns an error if the asset contains invalid values.

func (*Asset) XXX_DiscardUnknown 

func (m *Asset) XXX_DiscardUnknown()

func (*Asset) XXX_Marshal 

func (m *Asset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Asset) XXX_Merge 

func (dst *Asset) XXX_Merge(src proto.Message)

func (*Asset) XXX_Size 

func (m *Asset) XXX_Size() int

func (*Asset) XXX_Unmarshal 

func (m *Asset) XXX_Unmarshal(b []byte) error

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 

func FixtureCheck(id string) *Check

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 NewCheckFromFace(that CheckFace) *Check

func NewPopulatedCheck 

func NewPopulatedCheck(r randyCheck, easy bool) *Check

func (*Check) Descriptor 

func (*Check) Descriptor() ([]byte, []int)

func (*Check) Equal 

func (this *Check) Equal(that interface{}) bool

func (*Check) GetCheckHooks 

func (this *Check) GetCheckHooks() []HookList

func (*Check) GetCommand 

func (this *Check) GetCommand() string

func (*Check) GetCron 

func (this *Check) GetCron() string

func (*Check) GetDiscardOutput 

func (this *Check) GetDiscardOutput() bool

func (*Check) GetDuration 

func (this *Check) GetDuration() float64

func (*Check) GetEnvVars 

func (this *Check) GetEnvVars() []string

func (*Check) GetExecuted 

func (this *Check) GetExecuted() int64

func (*Check) GetExtendedAttributes 

func (this *Check) GetExtendedAttributes() []byte

func (*Check) GetHandlers 

func (this *Check) GetHandlers() []string

func (*Check) GetHighFlapThreshold 

func (this *Check) GetHighFlapThreshold() uint32

func (*Check) GetHistory 

func (this *Check) GetHistory() []CheckHistory

func (*Check) GetHooks 

func (this *Check) GetHooks() []*Hook

func (*Check) GetInterval 

func (this *Check) GetInterval() uint32

func (*Check) GetIssued 

func (this *Check) GetIssued() int64

func (*Check) GetLastOK 

func (this *Check) GetLastOK() int64

func (*Check) GetLowFlapThreshold 

func (this *Check) GetLowFlapThreshold() uint32

func (*Check) GetMaxOutputSize 

func (this *Check) GetMaxOutputSize() int64

func (*Check) GetObjectMeta 

func (this *Check) GetObjectMeta() ObjectMeta

func (*Check) GetOccurrences 

func (this *Check) GetOccurrences() int64

func (*Check) GetOccurrencesWatermark 

func (this *Check) GetOccurrencesWatermark() int64

func (*Check) GetOutput 

func (this *Check) GetOutput() string

func (*Check) GetOutputMetricFormat 

func (this *Check) GetOutputMetricFormat() string

func (*Check) GetOutputMetricHandlers 

func (this *Check) GetOutputMetricHandlers() []string

func (*Check) GetProxyEntityName 

func (this *Check) GetProxyEntityName() string

func (*Check) GetProxyRequests 

func (this *Check) GetProxyRequests() *ProxyRequests

func (*Check) GetPublish 

func (this *Check) GetPublish() bool

func (*Check) GetRoundRobin 

func (this *Check) GetRoundRobin() bool

func (*Check) GetRuntimeAssets 

func (this *Check) GetRuntimeAssets() []string

func (*Check) GetSilenced 

func (this *Check) GetSilenced() []string

func (*Check) GetState 

func (this *Check) GetState() string

func (*Check) GetStatus 

func (this *Check) GetStatus() uint32

func (*Check) GetStdin 

func (this *Check) GetStdin() bool

func (*Check) GetSubdue 

func (this *Check) GetSubdue() *TimeWindowWhen

func (*Check) GetSubscriptions 

func (this *Check) GetSubscriptions() []string

func (*Check) GetTimeout 

func (this *Check) GetTimeout() uint32

func (*Check) GetTotalStateChange 

func (this *Check) GetTotalStateChange() uint32

func (*Check) GetTtl 

func (this *Check) GetTtl() int64

func (*Check) Marshal 

func (m *Check) Marshal() (dAtA []byte, err error)

func (*Check) MarshalJSON 

func (c *Check) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*Check) MarshalTo 

func (m *Check) MarshalTo(dAtA []byte) (int, error)

func (*Check) MergeWith 

func (c *Check) MergeWith(prevCheck *Check)

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) Reset 

func (m *Check) Reset()

func (*Check) SetNamespace 

func (c *Check) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Check) Size 

func (m *Check) Size() (n int)

func (*Check) StorePrefix 

func (c *Check) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Check) String 

func (m *Check) String() string

func (*Check) TestProto 

func (this *Check) TestProto() github_com_golang_protobuf_proto.Message

func (*Check) URIPath 

func (c *Check) URIPath() string

URIPath returns the path component of a check URI.

func (*Check) Unmarshal 

func (m *Check) Unmarshal(dAtA []byte) error

func (*Check) Validate 

func (c *Check) Validate() error

Validate returns an error if the check does not pass validation tests.

func (*Check) XXX_DiscardUnknown 

func (m *Check) XXX_DiscardUnknown()

func (*Check) XXX_Marshal 

func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Check) XXX_Merge 

func (dst *Check) XXX_Merge(src proto.Message)

func (*Check) XXX_Size 

func (m *Check) XXX_Size() int

func (*Check) XXX_Unmarshal 

func (m *Check) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *CheckConfig) MarshalTo(dAtA []byte) (int, error)

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) MarshalTo 

func (m *CheckHistory) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CheckRequest) MarshalTo(dAtA []byte) (int, 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 

func FixtureClaims(username string, groups []string) *Claims

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) MarshalTo 

func (m *ClusterRole) MarshalTo(dAtA []byte) (int, 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) Validate 

func (r *ClusterRole) Validate() error

Validate a ClusterRole

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) MarshalTo 

func (m *Deregistration) MarshalTo(dAtA []byte) (int, 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 

func FixtureEntity(name string) *Entity

FixtureEntity returns a testing fixture for an Entity object.

func NewEntity 

func NewEntity(meta ObjectMeta) *Entity

NewEntity creates a new Entity.

func NewEntityFromFace 

func NewEntityFromFace(that EntityFace) *Entity

func NewPopulatedEntity 

func NewPopulatedEntity(r randyEntity, easy bool) *Entity

func (*Entity) Descriptor 

func (*Entity) Descriptor() ([]byte, []int)

func (*Entity) Equal 

func (this *Entity) Equal(that interface{}) bool

func (*Entity) GetDeregister 

func (this *Entity) GetDeregister() bool

func (*Entity) GetDeregistration 

func (this *Entity) GetDeregistration() Deregistration

func (*Entity) GetEntityClass 

func (this *Entity) GetEntityClass() string

func (*Entity) GetExtendedAttributes 

func (this *Entity) GetExtendedAttributes() []byte

func (*Entity) GetLastSeen 

func (this *Entity) GetLastSeen() int64

func (*Entity) GetObjectMeta 

func (this *Entity) GetObjectMeta() ObjectMeta

func (*Entity) GetRedact 

func (this *Entity) GetRedact() []string

func (*Entity) GetRedactedEntity 

func (e *Entity) GetRedactedEntity() *Entity

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 (this *Entity) GetSubscriptions() []string

func (*Entity) GetSystem 

func (this *Entity) GetSystem() System

func (*Entity) GetUser 

func (this *Entity) GetUser() string

func (*Entity) Marshal 

func (m *Entity) Marshal() (dAtA []byte, err error)

func (*Entity) MarshalJSON 

func (e *Entity) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*Entity) MarshalTo 

func (m *Entity) MarshalTo(dAtA []byte) (int, error)

func (*Entity) Proto 

func (this *Entity) Proto() github_com_golang_protobuf_proto.Message

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) SetNamespace 

func (e *Entity) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Entity) Size 

func (m *Entity) Size() (n int)

func (*Entity) StorePrefix 

func (e *Entity) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) TestProto 

func (this *Entity) TestProto() github_com_golang_protobuf_proto.Message

func (*Entity) URIPath 

func (e *Entity) URIPath() string

URIPath returns the path component of an entity URI.

func (*Entity) Unmarshal 

func (m *Entity) Unmarshal(dAtA []byte) error

func (*Entity) Validate 

func (e *Entity) Validate() error

Validate returns an error if the entity is invalid.

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge 

func (dst *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

func (m *Entity) XXX_Unmarshal(b []byte) error

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 

func FixtureEvent(entityName, checkID string) *Event

FixtureEvent returns a testing fixture for an Event object.

func NewEvent 

func NewEvent(meta ObjectMeta) *Event

NewEvent creates a new Event.

func NewEventFromFace 

func NewEventFromFace(that EventFace) *Event

func NewPopulatedEvent 

func NewPopulatedEvent(r randyEvent, easy bool) *Event

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) Equal 

func (this *Event) Equal(that interface{}) bool

func (*Event) GetCheck 

func (this *Event) GetCheck() *Check

func (*Event) GetEntity 

func (this *Event) GetEntity() *Entity

func (*Event) GetMetrics 

func (this *Event) GetMetrics() *Metrics

func (*Event) GetObjectMeta 

func (this *Event) GetObjectMeta() ObjectMeta

func (*Event) GetTimestamp 

func (this *Event) GetTimestamp() int64

func (*Event) HasCheck 

func (e *Event) HasCheck() bool

HasCheck determines if an event has check data.

func (*Event) HasMetrics 

func (e *Event) HasMetrics() bool

HasMetrics determines if an event has metric data.

func (*Event) IsIncident 

func (e *Event) IsIncident() bool

IsIncident determines if an event indicates an incident.

func (*Event) IsResolution 

func (e *Event) IsResolution() bool

IsResolution returns true if an event has just transitionned from an incident

func (*Event) IsSilenced 

func (e *Event) IsSilenced() bool

IsSilenced determines if an event has any silenced entries

func (*Event) IsSilencedBy 

func (e *Event) IsSilencedBy(entry *Silenced) bool

IsSilencedBy returns true if given silence will silence the event.

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) Proto 

func (this *Event) Proto() github_com_golang_protobuf_proto.Message

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) SetNamespace 

func (e *Event) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Event) SilencedBy 

func (e *Event) SilencedBy(entries []*Silenced) []*Silenced

SilencedBy returns the subset of given silences, that silence the event.

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) StorePrefix 

func (e *Event) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Event) String 

func (m *Event) String() string

func (*Event) SynthesizeExtras 

func (e *Event) SynthesizeExtras() map[string]interface{}

SynthesizeExtras implements dynamic.SynthesizeExtras

func (*Event) TestProto 

func (this *Event) TestProto() github_com_golang_protobuf_proto.Message

func (*Event) URIPath 

func (e *Event) URIPath() string

URIPath returns the path component of an event URI.

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) Validate 

func (e *Event) Validate() error

Validate returns an error if the event does not pass validation tests.

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *EventFilter) MarshalTo(dAtA []byte) (int, 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 

func FixtureExtension(name string) *Extension

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 NewPopulatedExtension(r randyExtension, easy bool) *Extension

func (*Extension) Descriptor 

func (*Extension) Descriptor() ([]byte, []int)

func (*Extension) Equal 

func (this *Extension) Equal(that interface{}) bool

func (*Extension) GetObjectMeta 

func (this *Extension) GetObjectMeta() ObjectMeta

func (*Extension) GetURL 

func (this *Extension) GetURL() string

func (*Extension) Marshal 

func (m *Extension) Marshal() (dAtA []byte, err error)

func (*Extension) MarshalTo 

func (m *Extension) MarshalTo(dAtA []byte) (int, error)

func (*Extension) Proto 

func (this *Extension) Proto() github_com_golang_protobuf_proto.Message

func (*Extension) ProtoMessage 

func (*Extension) ProtoMessage()

func (*Extension) Reset 

func (m *Extension) Reset()

func (*Extension) SetNamespace 

func (e *Extension) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Extension) Size 

func (m *Extension) Size() (n int)

func (*Extension) StorePrefix 

func (e *Extension) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Extension) String 

func (m *Extension) String() string

func (*Extension) TestProto 

func (this *Extension) TestProto() github_com_golang_protobuf_proto.Message

func (*Extension) URIPath 

func (e *Extension) URIPath() string

URIPath returns the path component of an extension URI.

func (*Extension) Unmarshal 

func (m *Extension) Unmarshal(dAtA []byte) error

func (*Extension) Validate 

func (e *Extension) Validate() error

Validate validates the extension.

func (*Extension) XXX_DiscardUnknown 

func (m *Extension) XXX_DiscardUnknown()

func (*Extension) XXX_Marshal 

func (m *Extension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Extension) XXX_Merge 

func (dst *Extension) XXX_Merge(src proto.Message)

func (*Extension) XXX_Size 

func (m *Extension) XXX_Size() int

func (*Extension) XXX_Unmarshal 

func (m *Extension) XXX_Unmarshal(b []byte) error

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 

func FakeHandlerCommand(command string, args ...string) *Handler

FakeHandlerCommand takes a command and (optionally) command args and will execute the TestHelperHandlerProcess test within the package FakeHandlerCommand is called from.

func FixtureHandler 

func FixtureHandler(name string) *Handler

FixtureHandler returns a Handler fixture for testing.

func FixtureSetHandler 

func FixtureSetHandler(name string, handlers ...string) *Handler

FixtureSetHandler returns a Handler fixture for testing.

func FixtureSocketHandler 

func FixtureSocketHandler(name string, proto string) *Handler

FixtureSocketHandler returns a Handler fixture for testing.

func NewHandler 

func NewHandler(meta ObjectMeta) *Handler

NewHandler creates a new Handler.

func NewHandlerFromFace 

func NewHandlerFromFace(that HandlerFace) *Handler

func NewPopulatedHandler 

func NewPopulatedHandler(r randyHandler, easy bool) *Handler

func (*Handler) Descriptor 

func (*Handler) Descriptor() ([]byte, []int)

func (*Handler) Equal 

func (this *Handler) Equal(that interface{}) bool

func (*Handler) GetCommand 

func (this *Handler) GetCommand() string

func (*Handler) GetEnvVars 

func (this *Handler) GetEnvVars() []string

func (*Handler) GetFilters 

func (this *Handler) GetFilters() []string

func (*Handler) GetHandlers 

func (this *Handler) GetHandlers() []string

func (*Handler) GetMutator 

func (this *Handler) GetMutator() string

func (*Handler) GetObjectMeta 

func (this *Handler) GetObjectMeta() ObjectMeta

func (*Handler) GetRuntimeAssets 

func (this *Handler) GetRuntimeAssets() []string

func (*Handler) GetSocket 

func (this *Handler) GetSocket() *HandlerSocket

func (*Handler) GetTimeout 

func (this *Handler) GetTimeout() uint32

func (*Handler) GetType 

func (this *Handler) GetType() string

func (*Handler) Marshal 

func (m *Handler) Marshal() (dAtA []byte, err error)

func (*Handler) MarshalTo 

func (m *Handler) MarshalTo(dAtA []byte) (int, error)

func (*Handler) Proto 

func (this *Handler) Proto() github_com_golang_protobuf_proto.Message

func (*Handler) ProtoMessage 

func (*Handler) ProtoMessage()

func (*Handler) Reset 

func (m *Handler) Reset()

func (*Handler) SetNamespace 

func (h *Handler) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Handler) Size 

func (m *Handler) Size() (n int)

func (*Handler) StorePrefix 

func (h *Handler) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Handler) String 

func (m *Handler) String() string

func (*Handler) TestProto 

func (this *Handler) TestProto() github_com_golang_protobuf_proto.Message

func (*Handler) URIPath 

func (h *Handler) URIPath() string

URIPath returns the path component of a handler URI.

func (*Handler) Unmarshal 

func (m *Handler) Unmarshal(dAtA []byte) error

func (*Handler) Validate 

func (h *Handler) Validate() error

Validate returns an error if the handler does not pass validation tests.

func (*Handler) XXX_DiscardUnknown 

func (m *Handler) XXX_DiscardUnknown()

func (*Handler) XXX_Marshal 

func (m *Handler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Handler) XXX_Merge 

func (dst *Handler) XXX_Merge(src proto.Message)

func (*Handler) XXX_Size 

func (m *Handler) XXX_Size() int

func (*Handler) XXX_Unmarshal 

func (m *Handler) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *HandlerSocket) MarshalTo(dAtA []byte) (int, 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 

func FixtureHook(id string) *Hook

FixtureHook returns a fixture for a Hook object.

func NewPopulatedHook 

func NewPopulatedHook(r randyHook, easy bool) *Hook

func (*Hook) Descriptor 

func (*Hook) Descriptor() ([]byte, []int)

func (*Hook) Equal 

func (this *Hook) Equal(that interface{}) bool

func (*Hook) GetDuration 

func (m *Hook) GetDuration() float64

func (*Hook) GetExecuted 

func (m *Hook) GetExecuted() int64

func (*Hook) GetIssued 

func (m *Hook) GetIssued() int64

func (*Hook) GetOutput 

func (m *Hook) GetOutput() string

func (*Hook) GetStatus 

func (m *Hook) GetStatus() int32

func (*Hook) Marshal 

func (m *Hook) Marshal() (dAtA []byte, err error)

func (*Hook) MarshalTo 

func (m *Hook) MarshalTo(dAtA []byte) (int, error)

func (*Hook) ProtoMessage 

func (*Hook) ProtoMessage()

func (*Hook) Reset 

func (m *Hook) Reset()

func (*Hook) SetNamespace 

func (h *Hook) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Hook) Size 

func (m *Hook) Size() (n int)

func (*Hook) String 

func (m *Hook) String() string

func (*Hook) URIPath 

func (h *Hook) URIPath() string

URIPath returns the path component of a Hook URI.

func (*Hook) Unmarshal 

func (m *Hook) Unmarshal(dAtA []byte) error

func (*Hook) Validate 

func (h *Hook) Validate() error

Validate returns an error if the hook does not pass validation tests.

func (*Hook) XXX_DiscardUnknown 

func (m *Hook) XXX_DiscardUnknown()

func (*Hook) XXX_Marshal 

func (m *Hook) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Hook) XXX_Merge 

func (dst *Hook) XXX_Merge(src proto.Message)

func (*Hook) XXX_Size 

func (m *Hook) XXX_Size() int

func (*Hook) XXX_Unmarshal 

func (m *Hook) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *HookConfig) MarshalTo(dAtA []byte) (int, 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 

func FixtureHookList(hookName string) *HookList

FixtureHookList returns a fixture for a HookList object.

func NewPopulatedHookList 

func NewPopulatedHookList(r randyHook, easy bool) *HookList

func (*HookList) Descriptor 

func (*HookList) Descriptor() ([]byte, []int)

func (*HookList) Equal 

func (this *HookList) Equal(that interface{}) bool

func (*HookList) GetHooks 

func (m *HookList) GetHooks() []string

func (*HookList) GetType 

func (m *HookList) GetType() string

func (*HookList) Marshal 

func (m *HookList) Marshal() (dAtA []byte, err error)

func (*HookList) MarshalJSON 

func (h *HookList) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HookList) MarshalTo 

func (m *HookList) MarshalTo(dAtA []byte) (int, error)

func (*HookList) ProtoMessage 

func (*HookList) ProtoMessage()

func (*HookList) Reset 

func (m *HookList) Reset()

func (*HookList) Size 

func (m *HookList) Size() (n int)

func (*HookList) String 

func (m *HookList) String() string

func (*HookList) Unmarshal 

func (m *HookList) Unmarshal(dAtA []byte) error

func (*HookList) UnmarshalJSON 

func (h *HookList) UnmarshalJSON(b []byte) error

UnmarshalJSON implements the json.Marshaler interface.

func (*HookList) Validate 

func (h *HookList) Validate() error

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 (m *HookList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HookList) XXX_Merge 

func (dst *HookList) XXX_Merge(src proto.Message)

func (*HookList) XXX_Size 

func (m *HookList) XXX_Size() int

func (*HookList) XXX_Unmarshal 

func (m *HookList) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *KeepaliveRecord) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MetricPoint) MarshalTo(dAtA []byte) (int, 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)

func (*MetricPoint) XXX_Size 

func (m *MetricPoint) XXX_Size() int

func (*MetricPoint) XXX_Unmarshal 

func (m *MetricPoint) XXX_Unmarshal(b []byte) error

type MetricTag 

type MetricTag struct {
	// The metric tag name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The metric tag value.
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A MetricTag adds a dimension to a metric point.

func FixtureMetricTag 

func FixtureMetricTag() *MetricTag

FixtureMetricTag returns a testing fixture for a Metric Tag object.

func NewPopulatedMetricTag 

func NewPopulatedMetricTag(r randyMetrics, easy bool) *MetricTag

func (*MetricTag) Descriptor 

func (*MetricTag) Descriptor() ([]byte, []int)

func (*MetricTag) Equal 

func (this *MetricTag) Equal(that interface{}) bool

func (*MetricTag) GetName 

func (m *MetricTag) GetName() string

func (*MetricTag) GetValue 

func (m *MetricTag) GetValue() string

func (*MetricTag) Marshal 

func (m *MetricTag) Marshal() (dAtA []byte, err error)

func (*MetricTag) MarshalTo 

func (m *MetricTag) MarshalTo(dAtA []byte) (int, error)

func (*MetricTag) ProtoMessage 

func (*MetricTag) ProtoMessage()

func (*MetricTag) Reset 

func (m *MetricTag) Reset()

func (*MetricTag) Size 

func (m *MetricTag) Size() (n int)

func (*MetricTag) String 

func (m *MetricTag) String() string

func (*MetricTag) Unmarshal 

func (m *MetricTag) Unmarshal(dAtA []byte) error

func (*MetricTag) XXX_DiscardUnknown 

func (m *MetricTag) XXX_DiscardUnknown()

func (*MetricTag) XXX_Marshal 

func (m *MetricTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricTag) XXX_Merge 

func (dst *MetricTag) XXX_Merge(src proto.Message)

func (*MetricTag) XXX_Size 

func (m *MetricTag) XXX_Size() int

func (*MetricTag) XXX_Unmarshal 

func (m *MetricTag) XXX_Unmarshal(b []byte) error

type Metrics 

type Metrics struct {
	// Handlers is a list of handlers for the metric points.
	Handlers []string `protobuf:"bytes,1,rep,name=handlers" json:"handlers"`
	// Points is a list of metric points (measurements).
	Points               []*MetricPoint `protobuf:"bytes,2,rep,name=points" json:"points"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

A Metrics is an event metrics payload specification.

func FixtureMetrics 

func FixtureMetrics() *Metrics

FixtureMetrics returns a testing fixture for a Metrics object.

func NewPopulatedMetrics 

func NewPopulatedMetrics(r randyMetrics, easy bool) *Metrics

func (*Metrics) Descriptor 

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) Equal 

func (this *Metrics) Equal(that interface{}) bool

func (*Metrics) GetHandlers 

func (m *Metrics) GetHandlers() []string

func (*Metrics) GetPoints 

func (m *Metrics) GetPoints() []*MetricPoint

func (*Metrics) Marshal 

func (m *Metrics) Marshal() (dAtA []byte, err error)

func (*Metrics) MarshalTo 

func (m *Metrics) MarshalTo(dAtA []byte) (int, error)

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) Size 

func (m *Metrics) Size() (n int)

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) Unmarshal 

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) Validate 

func (m *Metrics) Validate() error

Validate returns an error if metrics does not pass validation tests.

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge 

func (dst *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type MultitenantResource 

type MultitenantResource interface {
	GetNamespace() string
}

MultitenantResource is a object that belongs to a namespace

type Mutator 

type Mutator struct {
	// Metadata contains the name, namespace, labels and annotations of the mutator
	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 command execution timeout in seconds.
	Timeout uint32 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout"`
	// Env is a list of environment variables to use with command execution
	EnvVars []string `protobuf:"bytes,4,rep,name=env_vars,json=envVars" json:"env_vars"`
	// RuntimeAssets are a list of assets required to execute a mutator.
	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:"-"`
}

A Mutator is a mutator specification.

func FakeMutatorCommand 

func FakeMutatorCommand(command string, args ...string) *Mutator

FakeMutatorCommand takes a command and (optionally) command args and will execute the TestHelperMutatorProcess test within the package FakeMutatorCommand is called from.

func FixtureMutator 

func FixtureMutator(name string) *Mutator

FixtureMutator returns a Mutator fixture for testing.

func NewMutator 

func NewMutator(meta ObjectMeta) *Mutator

NewMutator creates a new Mutator.

func NewMutatorFromFace 

func NewMutatorFromFace(that MutatorFace) *Mutator

func NewPopulatedMutator 

func NewPopulatedMutator(r randyMutator, easy bool) *Mutator

func (*Mutator) Descriptor 

func (*Mutator) Descriptor() ([]byte, []int)

func (*Mutator) Equal 

func (this *Mutator) Equal(that interface{}) bool

func (*Mutator) GetCommand 

func (this *Mutator) GetCommand() string

func (*Mutator) GetEnvVars 

func (this *Mutator) GetEnvVars() []string

func (*Mutator) GetObjectMeta 

func (this *Mutator) GetObjectMeta() ObjectMeta

func (*Mutator) GetRuntimeAssets 

func (this *Mutator) GetRuntimeAssets() []string

func (*Mutator) GetTimeout 

func (this *Mutator) GetTimeout() uint32

func (*Mutator) Marshal 

func (m *Mutator) Marshal() (dAtA []byte, err error)

func (*Mutator) MarshalTo 

func (m *Mutator) MarshalTo(dAtA []byte) (int, error)

func (*Mutator) Proto 

func (this *Mutator) Proto() github_com_golang_protobuf_proto.Message

func (*Mutator) ProtoMessage 

func (*Mutator) ProtoMessage()

func (*Mutator) Reset 

func (m *Mutator) Reset()

func (*Mutator) SetNamespace 

func (m *Mutator) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Mutator) Size 

func (m *Mutator) Size() (n int)

func (*Mutator) StorePrefix 

func (m *Mutator) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Mutator) String 

func (m *Mutator) String() string

func (*Mutator) TestProto 

func (this *Mutator) TestProto() github_com_golang_protobuf_proto.Message

func (*Mutator) URIPath 

func (m *Mutator) URIPath() string

URIPath returns the path component of a mutator URI.

func (*Mutator) Unmarshal 

func (m *Mutator) Unmarshal(dAtA []byte) error

func (*Mutator) Update 

func (m *Mutator) Update(from *Mutator, fields ...string) error

Update updates m with selected fields. Returns non-nil error if any of the selected fields are unsupported.

func (*Mutator) Validate 

func (m *Mutator) Validate() error

Validate returns an error if the mutator does not pass validation tests.

func (*Mutator) XXX_DiscardUnknown 

func (m *Mutator) XXX_DiscardUnknown()

func (*Mutator) XXX_Marshal 

func (m *Mutator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mutator) XXX_Merge 

func (dst *Mutator) XXX_Merge(src proto.Message)

func (*Mutator) XXX_Size 

func (m *Mutator) XXX_Size() int

func (*Mutator) XXX_Unmarshal 

func (m *Mutator) XXX_Unmarshal(b []byte) error

type MutatorFace 

type MutatorFace interface {
	Proto() github_com_golang_protobuf_proto.Message
	GetObjectMeta() ObjectMeta
	GetCommand() string
	GetTimeout() uint32
	GetEnvVars() []string
	GetRuntimeAssets() []string
}

type Namespace 

type Namespace struct {
	// Name is the unique identifier for a namespace.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Namespace represents a virtual cluster

func FixtureNamespace 

func FixtureNamespace(name string) *Namespace

FixtureNamespace returns a mocked namespace

func NewPopulatedNamespace 

func NewPopulatedNamespace(r randyNamespace, easy bool) *Namespace

func (*Namespace) Descriptor 

func (*Namespace) Descriptor() ([]byte, []int)

func (*Namespace) Equal 

func (this *Namespace) Equal(that interface{}) bool

func (*Namespace) GetName 

func (m *Namespace) GetName() string

func (*Namespace) GetObjectMeta 

func (n *Namespace) GetObjectMeta() ObjectMeta

GetObjectMeta only exists here to fulfil the requirements of Resource

func (*Namespace) Marshal 

func (m *Namespace) Marshal() (dAtA []byte, err error)

func (*Namespace) MarshalTo 

func (m *Namespace) MarshalTo(dAtA []byte) (int, error)

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset 

func (m *Namespace) Reset()

func (*Namespace) SetNamespace 

func (n *Namespace) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Namespace) Size 

func (m *Namespace) Size() (n int)

func (*Namespace) StorePrefix 

func (n *Namespace) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Namespace) String 

func (m *Namespace) String() string

func (*Namespace) URIPath 

func (n *Namespace) URIPath() string

URIPath returns the path component of a Namespace URI.

func (*Namespace) Unmarshal 

func (m *Namespace) Unmarshal(dAtA []byte) error

func (*Namespace) Validate 

func (n *Namespace) Validate() error

Validate returns an error if the namespace does not pass validation tests

func (*Namespace) XXX_DiscardUnknown 

func (m *Namespace) XXX_DiscardUnknown()

func (*Namespace) XXX_Marshal 

func (m *Namespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Namespace) XXX_Merge 

func (dst *Namespace) XXX_Merge(src proto.Message)

func (*Namespace) XXX_Size 

func (m *Namespace) XXX_Size() int

func (*Namespace) XXX_Unmarshal 

func (m *Namespace) XXX_Unmarshal(b []byte) error

type Network 

type Network struct {
	Interfaces           []NetworkInterface `protobuf:"bytes,1,rep,name=interfaces" json:"interfaces"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Network contains information about the system network interfaces that the Agent process is running on, used for additional Entity context.

func NewPopulatedNetwork 

func NewPopulatedNetwork(r randyEntity, easy bool) *Network

func (*Network) Descriptor 

func (*Network) Descriptor() ([]byte, []int)

func (*Network) Equal 

func (this *Network) Equal(that interface{}) bool

func (*Network) GetInterfaces 

func (m *Network) GetInterfaces() []NetworkInterface

func (*Network) Marshal 

func (m *Network) Marshal() (dAtA []byte, err error)

func (*Network) MarshalTo 

func (m *Network) MarshalTo(dAtA []byte) (int, error)

func (*Network) ProtoMessage 

func (*Network) ProtoMessage()

func (*Network) Reset 

func (m *Network) Reset()

func (*Network) Size 

func (m *Network) Size() (n int)

func (*Network) String 

func (m *Network) String() string

func (*Network) Unmarshal 

func (m *Network) Unmarshal(dAtA []byte) error

func (*Network) XXX_DiscardUnknown 

func (m *Network) XXX_DiscardUnknown()

func (*Network) XXX_Marshal 

func (m *Network) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Network) XXX_Merge 

func (dst *Network) XXX_Merge(src proto.Message)

func (*Network) XXX_Size 

func (m *Network) XXX_Size() int

func (*Network) XXX_Unmarshal 

func (m *Network) XXX_Unmarshal(b []byte) error

type NetworkInterface 

type NetworkInterface struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MAC                  string   `protobuf:"bytes,2,opt,name=mac,proto3" json:"mac,omitempty"`
	Addresses            []string `protobuf:"bytes,3,rep,name=addresses" json:"addresses"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NetworkInterface contains information about a system network interface.

func NewPopulatedNetworkInterface 

func NewPopulatedNetworkInterface(r randyEntity, easy bool) *NetworkInterface

func (*NetworkInterface) Descriptor 

func (*NetworkInterface) Descriptor() ([]byte, []int)

func (*NetworkInterface) Equal 

func (this *NetworkInterface) Equal(that interface{}) bool

func (*NetworkInterface) GetAddresses 

func (m *NetworkInterface) GetAddresses() []string

func (*NetworkInterface) GetMAC 

func (m *NetworkInterface) GetMAC() string

func (*NetworkInterface) GetName 

func (m *NetworkInterface) GetName() string

func (*NetworkInterface) Marshal 

func (m *NetworkInterface) Marshal() (dAtA []byte, err error)

func (*NetworkInterface) MarshalTo 

func (m *NetworkInterface) MarshalTo(dAtA []byte) (int, error)

func (*NetworkInterface) ProtoMessage 

func (*NetworkInterface) ProtoMessage()

func (*NetworkInterface) Reset 

func (m *NetworkInterface) Reset()

func (*NetworkInterface) Size 

func (m *NetworkInterface) Size() (n int)

func (*NetworkInterface) String 

func (m *NetworkInterface) String() string

func (*NetworkInterface) Unmarshal 

func (m *NetworkInterface) Unmarshal(dAtA []byte) error

func (*NetworkInterface) XXX_DiscardUnknown 

func (m *NetworkInterface) XXX_DiscardUnknown()

func (*NetworkInterface) XXX_Marshal 

func (m *NetworkInterface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkInterface) XXX_Merge 

func (dst *NetworkInterface) XXX_Merge(src proto.Message)

func (*NetworkInterface) XXX_Size 

func (m *NetworkInterface) XXX_Size() int

func (*NetworkInterface) XXX_Unmarshal 

func (m *NetworkInterface) XXX_Unmarshal(b []byte) error

type ObjectMeta 

type ObjectMeta struct {
	// Name must be unique within a namespace. Name is primarily intended for creation
	// idempotence and configuration definition.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" yaml: "name,omitempty"`
	// Namespace defines a logical grouping of objects within which each object name must
	// be unique.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty" yaml: "namespace,omitempty"`
	// Map of string keys and values that can be used to organize and categorize
	// (scope and select) objects. May also be used in filters and token
	// substitution.
	// TODO: Link to Sensu documentation.
	// More info: http://kubernetes.io/docs/user-guide/labels
	Labels map[string]string `` /* 172-byte string literal not displayed */
	// Annotations is an unstructured key value map stored with a resource that may be
	// set by external tools to store and retrieve arbitrary metadata. They are not
	// queryable and should be preserved when modifying objects.
	// TODO: Link to Sensu documentation.
	// More info: http://kubernetes.io/docs/user-guide/annotations
	Annotations          map[string]string `` /* 186-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ObjectMeta is metadata all persisted objects have.

func NewObjectMeta 

func NewObjectMeta(name, namespace string) ObjectMeta

NewObjectMeta makes a new ObjectMeta, with Labels and Annotations assigned empty maps.

func NewPopulatedObjectMeta 

func NewPopulatedObjectMeta(r randyMeta, easy bool) *ObjectMeta

func (*ObjectMeta) Descriptor 

func (*ObjectMeta) Descriptor() ([]byte, []int)

func (*ObjectMeta) Equal 

func (this *ObjectMeta) Equal(that interface{}) bool

func (*ObjectMeta) GetAnnotations 

func (m *ObjectMeta) GetAnnotations() map[string]string

func (*ObjectMeta) GetLabels 

func (m *ObjectMeta) GetLabels() map[string]string

func (*ObjectMeta) GetName 

func (m *ObjectMeta) GetName() string

func (*ObjectMeta) GetNamespace 

func (m *ObjectMeta) GetNamespace() string

func (*ObjectMeta) Marshal 

func (m *ObjectMeta) Marshal() (dAtA []byte, err error)

func (*ObjectMeta) MarshalTo 

func (m *ObjectMeta) MarshalTo(dAtA []byte) (int, error)

func (*ObjectMeta) ProtoMessage 

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) Reset 

func (m *ObjectMeta) Reset()

func (*ObjectMeta) Size 

func (m *ObjectMeta) Size() (n int)

func (*ObjectMeta) String 

func (m *ObjectMeta) String() string

func (*ObjectMeta) Unmarshal 

func (m *ObjectMeta) Unmarshal(dAtA []byte) error

func (*ObjectMeta) XXX_DiscardUnknown 

func (m *ObjectMeta) XXX_DiscardUnknown()

func (*ObjectMeta) XXX_Marshal 

func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectMeta) XXX_Merge 

func (dst *ObjectMeta) XXX_Merge(src proto.Message)

func (*ObjectMeta) XXX_Size 

func (m *ObjectMeta) XXX_Size() int

func (*ObjectMeta) XXX_Unmarshal 

func (m *ObjectMeta) XXX_Unmarshal(b []byte) error

type ProxyRequests 

type ProxyRequests struct {
	// EntityAttributes store serialized arbitrary JSON-encoded data to match
	// entities in the registry.
	EntityAttributes []string `protobuf:"bytes,1,rep,name=entity_attributes,json=entityAttributes" json:"entity_attributes"`
	// Splay indicates if proxy check requests should be splayed, published
	// evenly over a window of time.
	Splay bool `protobuf:"varint,2,opt,name=splay,proto3" json:"splay"`
	// SplayCoverage is the percentage used for proxy check request splay
	// calculation.
	SplayCoverage        uint32   `protobuf:"varint,3,opt,name=splay_coverage,json=splayCoverage,proto3" json:"splay_coverage"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A ProxyRequests represents a request to execute a proxy check

func FixtureProxyRequests 

func FixtureProxyRequests(splay bool) *ProxyRequests

FixtureProxyRequests returns a fixture for a ProxyRequests object.

func NewPopulatedProxyRequests 

func NewPopulatedProxyRequests(r randyCheck, easy bool) *ProxyRequests

func (*ProxyRequests) Descriptor 

func (*ProxyRequests) Descriptor() ([]byte, []int)

func (*ProxyRequests) Equal 

func (this *ProxyRequests) Equal(that interface{}) bool

func (*ProxyRequests) GetEntityAttributes 

func (m *ProxyRequests) GetEntityAttributes() []string

func (*ProxyRequests) GetSplay 

func (m *ProxyRequests) GetSplay() bool

func (*ProxyRequests) GetSplayCoverage 

func (m *ProxyRequests) GetSplayCoverage() uint32

func (*ProxyRequests) Marshal 

func (m *ProxyRequests) Marshal() (dAtA []byte, err error)

func (*ProxyRequests) MarshalTo 

func (m *ProxyRequests) MarshalTo(dAtA []byte) (int, error)

func (*ProxyRequests) ProtoMessage 

func (*ProxyRequests) ProtoMessage()

func (*ProxyRequests) Reset 

func (m *ProxyRequests) Reset()

func (*ProxyRequests) Size 

func (m *ProxyRequests) Size() (n int)

func (*ProxyRequests) String 

func (m *ProxyRequests) String() string

func (*ProxyRequests) Unmarshal 

func (m *ProxyRequests) Unmarshal(dAtA []byte) error

func (*ProxyRequests) Validate 

func (p *ProxyRequests) Validate() error

Validate returns an error if the ProxyRequests does not pass validation tests

func (*ProxyRequests) XXX_DiscardUnknown 

func (m *ProxyRequests) XXX_DiscardUnknown()

func (*ProxyRequests) XXX_Marshal 

func (m *ProxyRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyRequests) XXX_Merge 

func (dst *ProxyRequests) XXX_Merge(src proto.Message)

func (*ProxyRequests) XXX_Size 

func (m *ProxyRequests) XXX_Size() int

func (*ProxyRequests) XXX_Unmarshal 

func (m *ProxyRequests) XXX_Unmarshal(b []byte) error

type Resource 

type Resource interface {
	// GetObjectMeta returns the object metadata for the resource.
	GetObjectMeta() ObjectMeta

	// SetNamespace sets the namespace of the resource.
	SetNamespace(string)

	// StorePrefix gives the path prefix to this resource in the store
	StorePrefix() string

	// URIPath gives the path to the resource, e.g. /checks/checkname
	URIPath() string

	// Validate checks if the fields in the resource are valid.
	Validate() error
}

Resource represents a Sensu resource.

func ResolveResource 

func ResolveResource(name string) (Resource, error)

ResolveResource returns a zero-valued resource, given a name. If the named type does not exist, or if the type is not a Resource, then an error will be returned.

type Role 

type Role struct {
	Rules []Rule `protobuf:"bytes,1,rep,name=rules" json:"rules"`
	// 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:"-"`
}

Role applies only to a single namespace.

func FixtureRole 

func FixtureRole(name, namespace string) *Role

FixtureRole returns a partial role

func NewPopulatedRole 

func NewPopulatedRole(r randyRbac, easy bool) *Role

func NewRole 

func NewRole(meta ObjectMeta) *Role

NewRole creates a new Role.

func NewRoleFromFace 

func NewRoleFromFace(that RoleFace) *Role

func (*Role) Descriptor 

func (*Role) Descriptor() ([]byte, []int)

func (*Role) Equal 

func (this *Role) Equal(that interface{}) bool

func (*Role) GetObjectMeta 

func (this *Role) GetObjectMeta() ObjectMeta

func (*Role) GetRules 

func (this *Role) GetRules() []Rule

func (*Role) Marshal 

func (m *Role) Marshal() (dAtA []byte, err error)

func (*Role) MarshalTo 

func (m *Role) MarshalTo(dAtA []byte) (int, error)

func (*Role) Proto 

func (this *Role) Proto() github_com_golang_protobuf_proto.Message

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) Reset 

func (m *Role) Reset()

func (*Role) SetNamespace 

func (r *Role) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Role) Size 

func (m *Role) Size() (n int)

func (*Role) StorePrefix 

func (r *Role) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Role) String 

func (m *Role) String() string

func (*Role) TestProto 

func (this *Role) TestProto() github_com_golang_protobuf_proto.Message

func (*Role) URIPath 

func (r *Role) URIPath() string

URIPath returns the path component of a role URI.

func (*Role) Unmarshal 

func (m *Role) Unmarshal(dAtA []byte) error

func (*Role) Validate 

func (r *Role) Validate() error

Validate a Role

func (*Role) XXX_DiscardUnknown 

func (m *Role) XXX_DiscardUnknown()

func (*Role) XXX_Marshal 

func (m *Role) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Role) XXX_Merge 

func (dst *Role) XXX_Merge(src proto.Message)

func (*Role) XXX_Size 

func (m *Role) XXX_Size() int

func (*Role) XXX_Unmarshal 

func (m *Role) XXX_Unmarshal(b []byte) error

type RoleBinding 

type RoleBinding struct {
	// Subjects holds references to the objects the Role applies to
	Subjects []Subject `protobuf:"bytes,1,rep,name=subjects" json:"subjects"`
	// RoleRef references a Role 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,5,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RoleBinding grants the permissions defined in a Role referenced to a user or a set of users

func FixtureRoleBinding 

func FixtureRoleBinding(name, namespace string) *RoleBinding

FixtureRoleBinding creates a RoleBinding for testing

func NewPopulatedRoleBinding 

func NewPopulatedRoleBinding(r randyRbac, easy bool) *RoleBinding

func NewRoleBinding 

func NewRoleBinding(meta ObjectMeta) *RoleBinding

NewRoleBinding creates a new RoleBinding.

func NewRoleBindingFromFace 

func NewRoleBindingFromFace(that RoleBindingFace) *RoleBinding

func (*RoleBinding) Descriptor 

func (*RoleBinding) Descriptor() ([]byte, []int)

func (*RoleBinding) Equal 

func (this *RoleBinding) Equal(that interface{}) bool

func (*RoleBinding) GetObjectMeta 

func (this *RoleBinding) GetObjectMeta() ObjectMeta

func (*RoleBinding) GetRoleRef 

func (this *RoleBinding) GetRoleRef() RoleRef

func (*RoleBinding) GetSubjects 

func (this *RoleBinding) GetSubjects() []Subject

func (*RoleBinding) Marshal 

func (m *RoleBinding) Marshal() (dAtA []byte, err error)

func (*RoleBinding) MarshalTo 

func (m *RoleBinding) MarshalTo(dAtA []byte) (int, error)

func (*RoleBinding) Proto 

func (this *RoleBinding) Proto() github_com_golang_protobuf_proto.Message

func (*RoleBinding) ProtoMessage 

func (*RoleBinding) ProtoMessage()

func (*RoleBinding) Reset 

func (m *RoleBinding) Reset()

func (*RoleBinding) SetNamespace 

func (b *RoleBinding) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*RoleBinding) Size 

func (m *RoleBinding) Size() (n int)

func (*RoleBinding) StorePrefix 

func (b *RoleBinding) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*RoleBinding) String 

func (m *RoleBinding) String() string

func (*RoleBinding) TestProto 

func (this *RoleBinding) TestProto() github_com_golang_protobuf_proto.Message

func (*RoleBinding) URIPath 

func (b *RoleBinding) URIPath() string

URIPath returns the path component of a role binding URI.

func (*RoleBinding) Unmarshal 

func (m *RoleBinding) Unmarshal(dAtA []byte) error

func (*RoleBinding) Validate 

func (b *RoleBinding) Validate() error

Validate a RoleBinding

func (*RoleBinding) XXX_DiscardUnknown 

func (m *RoleBinding) XXX_DiscardUnknown()

func (*RoleBinding) XXX_Marshal 

func (m *RoleBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoleBinding) XXX_Merge 

func (dst *RoleBinding) XXX_Merge(src proto.Message)

func (*RoleBinding) XXX_Size 

func (m *RoleBinding) XXX_Size() int

func (*RoleBinding) XXX_Unmarshal 

func (m *RoleBinding) XXX_Unmarshal(b []byte) error

type RoleBindingFace 

type RoleBindingFace interface {
	Proto() github_com_golang_protobuf_proto.Message
	GetSubjects() []Subject
	GetRoleRef() RoleRef
	GetObjectMeta() ObjectMeta
}

type RoleFace 

type RoleFace interface {
	Proto() github_com_golang_protobuf_proto.Message
	GetRules() []Rule
	GetObjectMeta() ObjectMeta
}

type RoleRef 

type RoleRef struct {
	// Type of role being referenced.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type"`
	// Name of the resource being referenced
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RoleRef maps groups to Roles or ClusterRoles.

func FixtureRoleRef 

func FixtureRoleRef(roleType, name string) RoleRef

FixtureRoleRef creates a RoleRef for testing

func NewPopulatedRoleRef 

func NewPopulatedRoleRef(r randyRbac, easy bool) *RoleRef

func (*RoleRef) Descriptor 

func (*RoleRef) Descriptor() ([]byte, []int)

func (*RoleRef) Equal 

func (this *RoleRef) Equal(that interface{}) bool

func (*RoleRef) GetName 

func (m *RoleRef) GetName() string

func (*RoleRef) GetType 

func (m *RoleRef) GetType() string

func (*RoleRef) Marshal 

func (m *RoleRef) Marshal() (dAtA []byte, err error)

func (*RoleRef) MarshalTo 

func (m *RoleRef) MarshalTo(dAtA []byte) (int, error)

func (*RoleRef) ProtoMessage 

func (*RoleRef) ProtoMessage()

func (*RoleRef) Reset 

func (m *RoleRef) Reset()

func (*RoleRef) Size 

func (m *RoleRef) Size() (n int)

func (*RoleRef) String 

func (m *RoleRef) String() string

func (*RoleRef) Unmarshal 

func (m *RoleRef) Unmarshal(dAtA []byte) error

func (*RoleRef) XXX_DiscardUnknown 

func (m *RoleRef) XXX_DiscardUnknown()

func (*RoleRef) XXX_Marshal 

func (m *RoleRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoleRef) XXX_Merge 

func (dst *RoleRef) XXX_Merge(src proto.Message)

func (*RoleRef) XXX_Size 

func (m *RoleRef) XXX_Size() int

func (*RoleRef) XXX_Unmarshal 

func (m *RoleRef) XXX_Unmarshal(b []byte) error

type Rule 

type Rule struct {
	// Verbs is a list of verbs that apply to all of the listed resources for this
	// rule. These include "get", "list", "watch", "create", "update", "delete".
	// TODO: add support for "patch" (this is expensive and should be delayed
	// until a further release). TODO: add support for "watch" (via websockets)
	Verbs []string `protobuf:"bytes,1,rep,name=verbs" json:"verbs"`
	// Resources is a list of resources that this rule applies to. "*" represents
	// all resources.
	Resources []string `protobuf:"bytes,2,rep,name=resources" json:"resources"`
	// ResourceNames is an optional list of resource names that the rule applies
	// to.
	ResourceNames        []string `protobuf:"bytes,3,rep,name=resource_names,json=resourceNames" json:"resource_names"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Rule holds information that describes an action that can be taken

func FixtureRule 

func FixtureRule() Rule

FixtureRule returns a partial rule

func NewPopulatedRule 

func NewPopulatedRule(r randyRbac, easy bool) *Rule

func (*Rule) Descriptor 

func (*Rule) Descriptor() ([]byte, []int)

func (*Rule) Equal 

func (this *Rule) Equal(that interface{}) bool

func (*Rule) GetResourceNames 

func (m *Rule) GetResourceNames() []string

func (*Rule) GetResources 

func (m *Rule) GetResources() []string

func (*Rule) GetVerbs 

func (m *Rule) GetVerbs() []string

func (*Rule) Marshal 

func (m *Rule) Marshal() (dAtA []byte, err error)

func (*Rule) MarshalTo 

func (m *Rule) MarshalTo(dAtA []byte) (int, error)

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) Reset 

func (m *Rule) Reset()

func (Rule) ResourceMatches 

func (r Rule) ResourceMatches(requestedResource string) bool

ResourceMatches returns whether the specified requestedResource matches any of the rule resources

func (Rule) ResourceNameMatches 

func (r Rule) ResourceNameMatches(requestedResourceName string) bool

ResourceNameMatches returns whether the specified requestedResourceName matches any of the rule resources

func (*Rule) Size 

func (m *Rule) Size() (n int)

func (*Rule) String 

func (m *Rule) String() string

func (*Rule) Unmarshal 

func (m *Rule) Unmarshal(dAtA []byte) error

func (Rule) VerbMatches 

func (r Rule) VerbMatches(requestedVerb string) bool

VerbMatches returns whether the specified requestedVerb matches any of the rule verbs

func (*Rule) XXX_DiscardUnknown 

func (m *Rule) XXX_DiscardUnknown()

func (*Rule) XXX_Marshal 

func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rule) XXX_Merge 

func (dst *Rule) XXX_Merge(src proto.Message)

func (*Rule) XXX_Size 

func (m *Rule) XXX_Size() int

func (*Rule) XXX_Unmarshal 

func (m *Rule) XXX_Unmarshal(b []byte) error

type Silenced 

type Silenced struct {
	// Metadata contains the name, namespace, labels and annotations of the silenced
	ObjectMeta `protobuf:"bytes,1,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"`
	// Expire is the number of seconds the entry will live
	Expire int64 `protobuf:"varint,2,opt,name=expire,proto3" json:"expire"`
	// ExpireOnResolve defaults to false, clears the entry on resolution when set
	// to true
	ExpireOnResolve bool `protobuf:"varint,3,opt,name=expire_on_resolve,json=expireOnResolve,proto3" json:"expire_on_resolve"`
	// Creator is the author of the silenced entry
	Creator string `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"`
	// Check is the name of the check event to be silenced.
	Check string `protobuf:"bytes,5,opt,name=check,proto3" json:"check,omitempty"`
	// Reason is used to provide context to the entry
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// Subscription is the name of the subscription to which the entry applies.
	Subscription string `protobuf:"bytes,7,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Begin is a timestamp at which the silenced entry takes effect.
	Begin                int64    `protobuf:"varint,10,opt,name=begin,proto3" json:"begin"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Silenced is the representation of a silence entry.

func FixtureSilenced 

func FixtureSilenced(name string) *Silenced

FixtureSilenced returns a testing fixutre for a Silenced event struct.

func NewPopulatedSilenced 

func NewPopulatedSilenced(r randySilenced, easy bool) *Silenced

func NewSilenced 

func NewSilenced(meta ObjectMeta) *Silenced

NewSilenced creates a new Silenced entry.

func NewSilencedFromFace 

func NewSilencedFromFace(that SilencedFace) *Silenced

func (*Silenced) Descriptor 

func (*Silenced) Descriptor() ([]byte, []int)

func (*Silenced) Equal 

func (this *Silenced) Equal(that interface{}) bool

func (*Silenced) GetBegin 

func (this *Silenced) GetBegin() int64

func (*Silenced) GetCheck 

func (this *Silenced) GetCheck() string

func (*Silenced) GetCreator 

func (this *Silenced) GetCreator() string

func (*Silenced) GetExpire 

func (this *Silenced) GetExpire() int64

func (*Silenced) GetExpireOnResolve 

func (this *Silenced) GetExpireOnResolve() bool

func (*Silenced) GetObjectMeta 

func (this *Silenced) GetObjectMeta() ObjectMeta

func (*Silenced) GetReason 

func (this *Silenced) GetReason() string

func (*Silenced) GetSubscription 

func (this *Silenced) GetSubscription() string

func (*Silenced) Marshal 

func (m *Silenced) Marshal() (dAtA []byte, err error)

func (*Silenced) MarshalTo 

func (m *Silenced) MarshalTo(dAtA []byte) (int, error)

func (*Silenced) Prepare 

func (s *Silenced) Prepare(ctx context.Context)

Prepare prepares a silenced entry for storage

func (*Silenced) Proto 

func (this *Silenced) Proto() github_com_golang_protobuf_proto.Message

func (*Silenced) ProtoMessage 

func (*Silenced) ProtoMessage()

func (*Silenced) Reset 

func (m *Silenced) Reset()

func (*Silenced) SetNamespace 

func (s *Silenced) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*Silenced) Size 

func (m *Silenced) Size() (n int)

func (*Silenced) StartSilence 

func (s *Silenced) StartSilence(currentTime int64) bool

StartSilence returns true if the current unix timestamp is less than the begin timestamp.

func (*Silenced) StorePrefix 

func (s *Silenced) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*Silenced) String 

func (m *Silenced) String() string

func (*Silenced) TestProto 

func (this *Silenced) TestProto() github_com_golang_protobuf_proto.Message

func (*Silenced) URIPath 

func (s *Silenced) URIPath() string

URIPath returns the path component of a silenced entry URI.

func (*Silenced) Unmarshal 

func (m *Silenced) Unmarshal(dAtA []byte) error

func (*Silenced) Validate 

func (s *Silenced) Validate() error

Validate returns an error if the CheckName and Subscription fields are not provided.

func (*Silenced) XXX_DiscardUnknown 

func (m *Silenced) XXX_DiscardUnknown()

func (*Silenced) XXX_Marshal 

func (m *Silenced) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Silenced) XXX_Merge 

func (dst *Silenced) XXX_Merge(src proto.Message)

func (*Silenced) XXX_Size 

func (m *Silenced) XXX_Size() int

func (*Silenced) XXX_Unmarshal 

func (m *Silenced) XXX_Unmarshal(b []byte) error

type SilencedFace 

type SilencedFace interface {
	Proto() github_com_golang_protobuf_proto.Message
	GetObjectMeta() ObjectMeta
	GetExpire() int64
	GetExpireOnResolve() bool
	GetCreator() string
	GetCheck() string
	GetReason() string
	GetSubscription() string
	GetBegin() int64
}

type Subject 

type Subject struct {
	// Type of object referenced (user or group)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type"`
	// Name of the referenced object
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func FixtureSubject 

func FixtureSubject(subjectType, name string) Subject

FixtureSubject creates a Subject for testing

func NewPopulatedSubject 

func NewPopulatedSubject(r randyRbac, easy bool) *Subject

func (*Subject) Descriptor 

func (*Subject) Descriptor() ([]byte, []int)

func (*Subject) Equal 

func (this *Subject) Equal(that interface{}) bool

func (*Subject) GetName 

func (m *Subject) GetName() string

func (*Subject) GetType 

func (m *Subject) GetType() string

func (*Subject) Marshal 

func (m *Subject) Marshal() (dAtA []byte, err error)

func (*Subject) MarshalTo 

func (m *Subject) MarshalTo(dAtA []byte) (int, error)

func (*Subject) ProtoMessage 

func (*Subject) ProtoMessage()

func (*Subject) Reset 

func (m *Subject) Reset()

func (*Subject) Size 

func (m *Subject) Size() (n int)

func (*Subject) String 

func (m *Subject) String() string

func (*Subject) Unmarshal 

func (m *Subject) Unmarshal(dAtA []byte) error

func (*Subject) XXX_DiscardUnknown 

func (m *Subject) XXX_DiscardUnknown()

func (*Subject) XXX_Marshal 

func (m *Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subject) XXX_Merge 

func (dst *Subject) XXX_Merge(src proto.Message)

func (*Subject) XXX_Size 

func (m *Subject) XXX_Size() int

func (*Subject) XXX_Unmarshal 

func (m *Subject) XXX_Unmarshal(b []byte) error

type System 

type System struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	OS                   string   `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Platform             string   `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	PlatformFamily       string   `protobuf:"bytes,4,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	PlatformVersion      string   `protobuf:"bytes,5,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	Network              Network  `protobuf:"bytes,6,opt,name=network" json:"network"`
	Arch                 string   `protobuf:"bytes,7,opt,name=arch,proto3" json:"arch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

System contains information about the system that the Agent process is running on, used for additional Entity context.

func NewPopulatedSystem 

func NewPopulatedSystem(r randyEntity, easy bool) *System

func (*System) Descriptor 

func (*System) Descriptor() ([]byte, []int)

func (*System) Equal 

func (this *System) Equal(that interface{}) bool

func (*System) GetArch 

func (m *System) GetArch() string

func (*System) GetHostname 

func (m *System) GetHostname() string

func (*System) GetNetwork 

func (m *System) GetNetwork() Network

func (*System) GetOS 

func (m *System) GetOS() string

func (*System) GetPlatform 

func (m *System) GetPlatform() string

func (*System) GetPlatformFamily 

func (m *System) GetPlatformFamily() string

func (*System) GetPlatformVersion 

func (m *System) GetPlatformVersion() string

func (*System) Marshal 

func (m *System) Marshal() (dAtA []byte, err error)

func (*System) MarshalTo 

func (m *System) MarshalTo(dAtA []byte) (int, error)

func (*System) ProtoMessage 

func (*System) ProtoMessage()

func (*System) Reset 

func (m *System) Reset()

func (*System) Size 

func (m *System) Size() (n int)

func (*System) String 

func (m *System) String() string

func (*System) Unmarshal 

func (m *System) Unmarshal(dAtA []byte) error

func (*System) XXX_DiscardUnknown 

func (m *System) XXX_DiscardUnknown()

func (*System) XXX_Marshal 

func (m *System) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*System) XXX_Merge 

func (dst *System) XXX_Merge(src proto.Message)

func (*System) XXX_Size 

func (m *System) XXX_Size() int

func (*System) XXX_Unmarshal 

func (m *System) XXX_Unmarshal(b []byte) error

type TLSOptions 

type TLSOptions struct {
	CertFile             string   `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"`
	KeyFile              string   `protobuf:"bytes,2,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"`
	TrustedCAFile        string   `protobuf:"bytes,3,opt,name=trusted_ca_file,json=trustedCaFile,proto3" json:"trusted_ca_file,omitempty"`
	InsecureSkipVerify   bool     `protobuf:"varint,4,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TLSOptions holds TLS options that are used across the varying Sensu components

func NewPopulatedTLSOptions 

func NewPopulatedTLSOptions(r randyTls, easy bool) *TLSOptions

func (*TLSOptions) Descriptor 

func (*TLSOptions) Descriptor() ([]byte, []int)

func (*TLSOptions) Equal 

func (this *TLSOptions) Equal(that interface{}) bool

func (*TLSOptions) GetCertFile 

func (m *TLSOptions) GetCertFile() string

func (*TLSOptions) GetInsecureSkipVerify 

func (m *TLSOptions) GetInsecureSkipVerify() bool

func (*TLSOptions) GetKeyFile 

func (m *TLSOptions) GetKeyFile() string

func (*TLSOptions) GetTrustedCAFile 

func (m *TLSOptions) GetTrustedCAFile() string

func (*TLSOptions) Marshal 

func (m *TLSOptions) Marshal() (dAtA []byte, err error)

func (*TLSOptions) MarshalTo 

func (m *TLSOptions) MarshalTo(dAtA []byte) (int, error)

func (*TLSOptions) ProtoMessage 

func (*TLSOptions) ProtoMessage()

func (*TLSOptions) Reset 

func (m *TLSOptions) Reset()

func (*TLSOptions) Size 

func (m *TLSOptions) Size() (n int)

func (*TLSOptions) String 

func (m *TLSOptions) String() string

func (*TLSOptions) ToClientTLSConfig 

func (t *TLSOptions) ToClientTLSConfig() (*tls.Config, error)

ToClientTLSConfig is like ToServerTLSConfig but intended for TLS client config.

func (*TLSOptions) ToServerTLSConfig 

func (t *TLSOptions) ToServerTLSConfig() (*tls.Config, error)

ToServerTLSConfig should only be used for server TLS configuration. outputs a tls.Config from TLSOptions

func (*TLSOptions) Unmarshal 

func (m *TLSOptions) Unmarshal(dAtA []byte) error

func (*TLSOptions) XXX_DiscardUnknown 

func (m *TLSOptions) XXX_DiscardUnknown()

func (*TLSOptions) XXX_Marshal 

func (m *TLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TLSOptions) XXX_Merge 

func (dst *TLSOptions) XXX_Merge(src proto.Message)

func (*TLSOptions) XXX_Size 

func (m *TLSOptions) XXX_Size() int

func (*TLSOptions) XXX_Unmarshal 

func (m *TLSOptions) XXX_Unmarshal(b []byte) error

type TessenConfig 

type TessenConfig struct {
	// OptOut is the opt-out status of the tessen configuration
	OptOut               bool     `protobuf:"varint,1,opt,name=opt_out,json=optOut,proto3" json:"opt_out"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TessenConfig is the representation of a tessen configuration.

func DefaultTessenConfig 

func DefaultTessenConfig() *TessenConfig

DefaultTessenConfig returns the default tessen configuration

func NewPopulatedTessenConfig 

func NewPopulatedTessenConfig(r randyTessen, easy bool) *TessenConfig

func NewTessenConfigFromFace 

func NewTessenConfigFromFace(that TessenConfigFace) *TessenConfig

func (*TessenConfig) Descriptor 

func (*TessenConfig) Descriptor() ([]byte, []int)

func (*TessenConfig) Equal 

func (this *TessenConfig) Equal(that interface{}) bool

func (*TessenConfig) GetObjectMeta 

func (t *TessenConfig) GetObjectMeta() ObjectMeta

GetObjectMeta only exists here to fulfil the requirements of Resource

func (*TessenConfig) GetOptOut 

func (this *TessenConfig) GetOptOut() bool

func (*TessenConfig) Marshal 

func (m *TessenConfig) Marshal() (dAtA []byte, err error)

func (*TessenConfig) MarshalTo 

func (m *TessenConfig) MarshalTo(dAtA []byte) (int, error)

func (*TessenConfig) Proto 

func (this *TessenConfig) Proto() github_com_golang_protobuf_proto.Message

func (*TessenConfig) ProtoMessage 

func (*TessenConfig) ProtoMessage()

func (*TessenConfig) Reset 

func (m *TessenConfig) Reset()

func (*TessenConfig) SetNamespace 

func (t *TessenConfig) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*TessenConfig) Size 

func (m *TessenConfig) Size() (n int)

func (*TessenConfig) StorePrefix 

func (t *TessenConfig) StorePrefix() string

StorePrefix returns the path prefix to the Tessen config in the store

func (*TessenConfig) String 

func (m *TessenConfig) String() string

func (*TessenConfig) TestProto 

func (this *TessenConfig) TestProto() github_com_golang_protobuf_proto.Message

func (*TessenConfig) URIPath 

func (t *TessenConfig) URIPath() string

URIPath returns the path component of the Tessen config URI.

func (*TessenConfig) Unmarshal 

func (m *TessenConfig) Unmarshal(dAtA []byte) error

func (*TessenConfig) Validate 

func (t *TessenConfig) Validate() error

Validate validates the TessenConfig.

func (*TessenConfig) XXX_DiscardUnknown 

func (m *TessenConfig) XXX_DiscardUnknown()

func (*TessenConfig) XXX_Marshal 

func (m *TessenConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TessenConfig) XXX_Merge 

func (dst *TessenConfig) XXX_Merge(src proto.Message)

func (*TessenConfig) XXX_Size 

func (m *TessenConfig) XXX_Size() int

func (*TessenConfig) XXX_Unmarshal 

func (m *TessenConfig) XXX_Unmarshal(b []byte) error

type TessenConfigFace 

type TessenConfigFace interface {
	Proto() github_com_golang_protobuf_proto.Message
	GetOptOut() bool
}

type TimeWindowDays 

type TimeWindowDays struct {
	All                  []*TimeWindowTimeRange `protobuf:"bytes,1,rep,name=all" json:"all,omitempty"`
	Sunday               []*TimeWindowTimeRange `protobuf:"bytes,2,rep,name=sunday" json:"sunday,omitempty"`
	Monday               []*TimeWindowTimeRange `protobuf:"bytes,3,rep,name=monday" json:"monday,omitempty"`
	Tuesday              []*TimeWindowTimeRange `protobuf:"bytes,4,rep,name=tuesday" json:"tuesday,omitempty"`
	Wednesday            []*TimeWindowTimeRange `protobuf:"bytes,5,rep,name=wednesday" json:"wednesday,omitempty"`
	Thursday             []*TimeWindowTimeRange `protobuf:"bytes,6,rep,name=thursday" json:"thursday,omitempty"`
	Friday               []*TimeWindowTimeRange `protobuf:"bytes,7,rep,name=friday" json:"friday,omitempty"`
	Saturday             []*TimeWindowTimeRange `protobuf:"bytes,8,rep,name=saturday" json:"saturday,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

TimeWindowDays defines the days of a time window

func NewPopulatedTimeWindowDays 

func NewPopulatedTimeWindowDays(r randyTimeWindow, easy bool) *TimeWindowDays

func (*TimeWindowDays) Descriptor 

func (*TimeWindowDays) Descriptor() ([]byte, []int)

func (*TimeWindowDays) Equal 

func (this *TimeWindowDays) Equal(that interface{}) bool

func (*TimeWindowDays) GetAll 

func (m *TimeWindowDays) GetAll() []*TimeWindowTimeRange

func (*TimeWindowDays) GetFriday 

func (m *TimeWindowDays) GetFriday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetMonday 

func (m *TimeWindowDays) GetMonday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetSaturday 

func (m *TimeWindowDays) GetSaturday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetSunday 

func (m *TimeWindowDays) GetSunday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetThursday 

func (m *TimeWindowDays) GetThursday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetTuesday 

func (m *TimeWindowDays) GetTuesday() []*TimeWindowTimeRange

func (*TimeWindowDays) GetWednesday 

func (m *TimeWindowDays) GetWednesday() []*TimeWindowTimeRange

func (*TimeWindowDays) Marshal 

func (m *TimeWindowDays) Marshal() (dAtA []byte, err error)

func (*TimeWindowDays) MarshalTo 

func (m *TimeWindowDays) MarshalTo(dAtA []byte) (int, error)

func (*TimeWindowDays) ProtoMessage 

func (*TimeWindowDays) ProtoMessage()

func (*TimeWindowDays) Reset 

func (m *TimeWindowDays) Reset()

func (*TimeWindowDays) Size 

func (m *TimeWindowDays) Size() (n int)

func (*TimeWindowDays) String 

func (m *TimeWindowDays) String() string

func (*TimeWindowDays) Unmarshal 

func (m *TimeWindowDays) Unmarshal(dAtA []byte) error

func (*TimeWindowDays) XXX_DiscardUnknown 

func (m *TimeWindowDays) XXX_DiscardUnknown()

func (*TimeWindowDays) XXX_Marshal 

func (m *TimeWindowDays) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeWindowDays) XXX_Merge 

func (dst *TimeWindowDays) XXX_Merge(src proto.Message)

func (*TimeWindowDays) XXX_Size 

func (m *TimeWindowDays) XXX_Size() int

func (*TimeWindowDays) XXX_Unmarshal 

func (m *TimeWindowDays) XXX_Unmarshal(b []byte) error

type TimeWindowTimeRange 

type TimeWindowTimeRange struct {
	// Begin is the time which the time window should begin, in the format
	// '3:00PM', which satisfies the time.Kitchen format
	Begin string `protobuf:"bytes,1,opt,name=begin,proto3" json:"begin"`
	// End is the time which the filter should end, in the format '3:00PM', which
	// satisfies the time.Kitchen format
	End                  string   `protobuf:"bytes,2,opt,name=end,proto3" json:"end"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeWindowTimeRange defines the time ranges of a time

func NewPopulatedTimeWindowTimeRange 

func NewPopulatedTimeWindowTimeRange(r randyTimeWindow, easy bool) *TimeWindowTimeRange

func (*TimeWindowTimeRange) Descriptor 

func (*TimeWindowTimeRange) Descriptor() ([]byte, []int)

func (*TimeWindowTimeRange) Equal 

func (this *TimeWindowTimeRange) Equal(that interface{}) bool

func (*TimeWindowTimeRange) GetBegin 

func (m *TimeWindowTimeRange) GetBegin() string

func (*TimeWindowTimeRange) GetEnd 

func (m *TimeWindowTimeRange) GetEnd() string

func (*TimeWindowTimeRange) InWindow 

func (t *TimeWindowTimeRange) InWindow(current time.Time) (bool, error)

InWindow determines if the current time falls between the provided time window. Current should typically be time.Now() but to allow easier tests, it must be provided as a parameter. Begin and end parameters must be strings representing an hour of the day in the time.Kitchen format (e.g. "3:04PM")

func (*TimeWindowTimeRange) Marshal 

func (m *TimeWindowTimeRange) Marshal() (dAtA []byte, err error)

func (*TimeWindowTimeRange) MarshalTo 

func (m *TimeWindowTimeRange) MarshalTo(dAtA []byte) (int, error)

func (*TimeWindowTimeRange) ProtoMessage 

func (*TimeWindowTimeRange) ProtoMessage()

func (*TimeWindowTimeRange) Reset 

func (m *TimeWindowTimeRange) Reset()

func (*TimeWindowTimeRange) Size 

func (m *TimeWindowTimeRange) Size() (n int)

func (*TimeWindowTimeRange) String 

func (m *TimeWindowTimeRange) String() string

func (*TimeWindowTimeRange) Unmarshal 

func (m *TimeWindowTimeRange) Unmarshal(dAtA []byte) error

func (*TimeWindowTimeRange) Validate 

func (t *TimeWindowTimeRange) Validate() error

Validate ensures the TimeWindowTimeRange is valid.

func (*TimeWindowTimeRange) XXX_DiscardUnknown 

func (m *TimeWindowTimeRange) XXX_DiscardUnknown()

func (*TimeWindowTimeRange) XXX_Marshal 

func (m *TimeWindowTimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeWindowTimeRange) XXX_Merge 

func (dst *TimeWindowTimeRange) XXX_Merge(src proto.Message)

func (*TimeWindowTimeRange) XXX_Size 

func (m *TimeWindowTimeRange) XXX_Size() int

func (*TimeWindowTimeRange) XXX_Unmarshal 

func (m *TimeWindowTimeRange) XXX_Unmarshal(b []byte) error

type TimeWindowWhen 

type TimeWindowWhen struct {
	// Days is a hash of days
	Days                 TimeWindowDays `protobuf:"bytes,1,opt,name=days" json:"days"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

TimeWindowWhen defines the "when" attributes for time windows

func NewPopulatedTimeWindowWhen 

func NewPopulatedTimeWindowWhen(r randyTimeWindow, easy bool) *TimeWindowWhen

func (*TimeWindowWhen) Descriptor 

func (*TimeWindowWhen) Descriptor() ([]byte, []int)

func (*TimeWindowWhen) Equal 

func (this *TimeWindowWhen) Equal(that interface{}) bool

func (*TimeWindowWhen) GetDays 

func (m *TimeWindowWhen) GetDays() TimeWindowDays

func (*TimeWindowWhen) InWindows 

func (t *TimeWindowWhen) InWindows(current time.Time) (bool, error)

InWindows determines if the current time falls between the provided time windows. Current should typically be time.Now() but to allow easier tests, it must be provided as a parameter. The function returns a positive value as soon the current time falls within a time window

func (*TimeWindowWhen) MapTimeWindows 

func (t *TimeWindowWhen) MapTimeWindows() map[string][]*TimeWindowTimeRange

MapTimeWindows returns a map of all the time windows in t.

func (*TimeWindowWhen) Marshal 

func (m *TimeWindowWhen) Marshal() (dAtA []byte, err error)

func (*TimeWindowWhen) MarshalTo 

func (m *TimeWindowWhen) MarshalTo(dAtA []byte) (int, error)

func (*TimeWindowWhen) ProtoMessage 

func (*TimeWindowWhen) ProtoMessage()

func (*TimeWindowWhen) Reset 

func (m *TimeWindowWhen) Reset()

func (*TimeWindowWhen) Size 

func (m *TimeWindowWhen) Size() (n int)

func (*TimeWindowWhen) String 

func (m *TimeWindowWhen) String() string

func (*TimeWindowWhen) Unmarshal 

func (m *TimeWindowWhen) Unmarshal(dAtA []byte) error

func (*TimeWindowWhen) Validate 

func (t *TimeWindowWhen) Validate() error

Validate ensures that all the time windows in t can be parsed.

func (*TimeWindowWhen) XXX_DiscardUnknown 

func (m *TimeWindowWhen) XXX_DiscardUnknown()

func (*TimeWindowWhen) XXX_Marshal 

func (m *TimeWindowWhen) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeWindowWhen) XXX_Merge 

func (dst *TimeWindowWhen) XXX_Merge(src proto.Message)

func (*TimeWindowWhen) XXX_Size 

func (m *TimeWindowWhen) XXX_Size() int

func (*TimeWindowWhen) XXX_Unmarshal 

func (m *TimeWindowWhen) XXX_Unmarshal(b []byte) error

type Tokens 

type Tokens struct {
	// Access token is used by client to make request
	Access string `protobuf:"bytes,1,opt,name=access,proto3" json:"access_token"`
	// ExpiresAt unix timestamp describing when the access token is no longer valid
	ExpiresAt int64 `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at"`
	// Refresh token is used by client to request a new access token
	Refresh              string   `protobuf:"bytes,3,opt,name=refresh,proto3" json:"refresh_token"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Tokens contains the structure for exchanging tokens with the API

func FixtureTokens 

func FixtureTokens(accessToken, refreshToken string) *Tokens

FixtureTokens given an access and refresh tokens returns valid tokens for use in tests

func NewPopulatedTokens 

func NewPopulatedTokens(r randyAuthentication, easy bool) *Tokens

func (*Tokens) Descriptor 

func (*Tokens) Descriptor() ([]byte, []int)

func (*Tokens) Equal 

func (this *Tokens) Equal(that interface{}) bool

func (*Tokens) GetAccess 

func (m *Tokens) GetAccess() string

func (*Tokens) GetExpiresAt 

func (m *Tokens) GetExpiresAt() int64

func (*Tokens) GetRefresh 

func (m *Tokens) GetRefresh() string

func (*Tokens) Marshal 

func (m *Tokens) Marshal() (dAtA []byte, err error)

func (*Tokens) MarshalTo 

func (m *Tokens) MarshalTo(dAtA []byte) (int, error)

func (*Tokens) ProtoMessage 

func (*Tokens) ProtoMessage()

func (*Tokens) Reset 

func (m *Tokens) Reset()

func (*Tokens) Size 

func (m *Tokens) Size() (n int)

func (*Tokens) String 

func (m *Tokens) String() string

func (*Tokens) Unmarshal 

func (m *Tokens) Unmarshal(dAtA []byte) error

func (*Tokens) Validate 

func (t *Tokens) Validate() error

Validate returns an error if the tokens contain invalid values.

func (*Tokens) XXX_DiscardUnknown 

func (m *Tokens) XXX_DiscardUnknown()

func (*Tokens) XXX_Marshal 

func (m *Tokens) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tokens) XXX_Merge 

func (dst *Tokens) XXX_Merge(src proto.Message)

func (*Tokens) XXX_Size 

func (m *Tokens) XXX_Size() int

func (*Tokens) XXX_Unmarshal 

func (m *Tokens) XXX_Unmarshal(b []byte) error

type TypeMeta 

type TypeMeta struct {
	// Type is the type name of the data type
	Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"type" yaml: "type,omitempty"`
	// APIVersion is the APIVersion of the data type
	APIVersion           string   `protobuf:"bytes,2,opt,name=APIVersion,proto3" json:"api_version" yaml: "api_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TypeMeta is information that can be used to resolve a data type

func NewPopulatedTypeMeta 

func NewPopulatedTypeMeta(r randyMeta, easy bool) *TypeMeta

func (*TypeMeta) Descriptor 

func (*TypeMeta) Descriptor() ([]byte, []int)

func (*TypeMeta) Equal 

func (this *TypeMeta) Equal(that interface{}) bool

func (*TypeMeta) GetAPIVersion 

func (m *TypeMeta) GetAPIVersion() string

func (*TypeMeta) GetType 

func (m *TypeMeta) GetType() string

func (*TypeMeta) Marshal 

func (m *TypeMeta) Marshal() (dAtA []byte, err error)

func (*TypeMeta) MarshalTo 

func (m *TypeMeta) MarshalTo(dAtA []byte) (int, error)

func (*TypeMeta) ProtoMessage 

func (*TypeMeta) ProtoMessage()

func (*TypeMeta) Reset 

func (m *TypeMeta) Reset()

func (*TypeMeta) Size 

func (m *TypeMeta) Size() (n int)

func (*TypeMeta) String 

func (m *TypeMeta) String() string

func (*TypeMeta) Unmarshal 

func (m *TypeMeta) Unmarshal(dAtA []byte) error

func (*TypeMeta) XXX_DiscardUnknown 

func (m *TypeMeta) XXX_DiscardUnknown()

func (*TypeMeta) XXX_Marshal 

func (m *TypeMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TypeMeta) XXX_Merge 

func (dst *TypeMeta) XXX_Merge(src proto.Message)

func (*TypeMeta) XXX_Size 

func (m *TypeMeta) XXX_Size() int

func (*TypeMeta) XXX_Unmarshal 

func (m *TypeMeta) XXX_Unmarshal(b []byte) error

type User 

type User struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Groups               []string `protobuf:"bytes,3,rep,name=groups" json:"groups,omitempty"`
	Disabled             bool     `protobuf:"varint,4,opt,name=disabled,proto3" json:"disabled"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User describes an authenticated user

func FixtureUser 

func FixtureUser(username string) *User

FixtureUser returns a testing fixture for an Entity object.

func NewPopulatedUser 

func NewPopulatedUser(r randyUser, easy bool) *User

func (*User) Descriptor 

func (*User) Descriptor() ([]byte, []int)

func (*User) Equal 

func (this *User) Equal(that interface{}) bool

func (*User) GetDisabled 

func (m *User) GetDisabled() bool

func (*User) GetGroups 

func (m *User) GetGroups() []string

func (*User) GetObjectMeta 

func (u *User) GetObjectMeta() ObjectMeta

GetObjectMeta is a dummy implementation to meet the Resource interface.

func (*User) GetPassword 

func (m *User) GetPassword() string

func (*User) GetUsername 

func (m *User) GetUsername() string

func (*User) Marshal 

func (m *User) Marshal() (dAtA []byte, err error)

func (*User) MarshalTo 

func (m *User) MarshalTo(dAtA []byte) (int, error)

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) SetNamespace 

func (u *User) SetNamespace(namespace string)

SetNamespace sets the namespace of the resource.

func (*User) Size 

func (m *User) Size() (n int)

func (*User) StorePrefix 

func (u *User) StorePrefix() string

StorePrefix returns the path prefix to this resource in the store

func (*User) String 

func (m *User) String() string

func (*User) URIPath 

func (u *User) URIPath() string

URIPath is the URI path component to a user.

func (*User) Unmarshal 

func (m *User) Unmarshal(dAtA []byte) error

func (*User) Validate 

func (u *User) Validate() error

Validate returns an error if the entity is invalid.

func (*User) ValidatePassword 

func (u *User) ValidatePassword() error

ValidatePassword returns an error if the entity is invalid.

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge 

func (dst *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

func (m *User) XXX_Unmarshal(b []byte) error

type Version 

type Version struct {
	Etcd         *etcdVersion.Versions `json:"etcd"`
	SensuBackend string                `json:"sensu_backend"`
}

Version holds the current etcd server and cluster version, and the sensu-backend version.

func FixtureVersion 

func FixtureVersion() *Version

FixtureVersion returns a Version fixture for testing.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.