types

package
v0.0.0-...-7cb4b9d Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2018 License: MIT, MIT Imports: 29 Imported by: 0

Documentation

Overview

Package types is a generated protocol buffer package.

It is generated from these files: 

adhoc.proto
any.proto
asset.proto
authentication.proto
check.proto
entity.proto
environment.proto
error.proto
event.proto
extension.proto
filter.proto
handler.proto
hook.proto
keepalive.proto
metrics.proto
mutator.proto
organization.proto
rbac.proto
silenced.proto
time_window.proto
tls.proto
user.proto

It has these top-level messages: 

AdhocRequest
Any
Asset
Tokens
CheckRequest
ProxyRequests
CheckConfig
Check
CheckHistory
Entity
System
Network
NetworkInterface
Deregistration
Environment
Error
Event
Extension
EventFilter
Handler
HandlerSocket
HookConfig
Hook
HookList
KeepaliveRecord
Metrics
MetricPoint
MetricTag
Mutator
Organization
Rule
Role
Silenced
TimeWindowWhen
TimeWindowDays
TimeWindowTimeRange
TLSOptions
User

Index

Constants

View Source 
const (
	// AuthorizationActorKey is the key name used to store a user's details within
	// a context
	AuthorizationActorKey key = iota
	// AuthorizationRoleKey is the key name used to store a user's roles within
	// a context TODO: Remove
	AuthorizationRoleKey
	// AccessTokenClaims contains the key name to retrieve the access token claims
	AccessTokenClaims
	// ClaimsKey contains key name to retrieve the jwt claims from context
	ClaimsKey
	// EnvironmentKey contains the key name to retrieve the env from context
	EnvironmentKey
	// OrganizationKey contains the key name to retrieve the org from context
	OrganizationKey
	// RefreshTokenClaims contains the key name to retrieve the refresh token claims
	RefreshTokenClaims
	// RefreshTokenString contains the key name to retrieve the refresh token string
	RefreshTokenString
	// StoreKey contains the key name to retrieve the etcd store from within a context
	StoreKey
)
View Source 
const (
	// 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"
)
View Source 
const (
	// 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 (
	// 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"
)
View Source 
const (
	// RuleTypeAll matches all actions
	RuleTypeAll = "*"

	// RulePermCreate create action
	RulePermCreate = "create"

	// RulePermRead read action
	RulePermRead = "read"

	// RulePermUpdate update action
	RulePermUpdate = "update"

	// RulePermDelete delete action
	RulePermDelete = "delete"

	// RuleTypeAsset access control for asset objects
	RuleTypeAsset = "assets"

	// RuleTypeCheck access control for check objects
	RuleTypeCheck = "checks"

	// RuleTypeEntity access control for entity objects
	RuleTypeEntity = "entities"

	// RuleTypeEnvironment access control for organization objects
	RuleTypeEnvironment = "environments"

	// RuleTypeEvent access control for event objects
	RuleTypeEvent = "events"

	// RuleTypeEventFilter access control for filter objects
	RuleTypeEventFilter = "filters"

	// RuleTypeExtension access control for extension registry
	RuleTypeExtension = "extensions"

	// RuleTypeHandler access control for handler objects
	RuleTypeHandler = "handlers"

	// RuleTypeHook access control for hook objects
	RuleTypeHook = "hooks"

	// RuleTypeMutator access control for mutator objects
	RuleTypeMutator = "mutators"

	// RuleTypeOrganization access control for organization objects
	RuleTypeOrganization = "organizations"

	// RuleTypeRole access control for role objects
	RuleTypeRole = "roles"

	// RuleTypeSilenced access control for silenced objects
	RuleTypeSilenced = "silenced"

	// RuleTypeUser access control for user objects
	RuleTypeUser = "users"
)
View Source 
const AgentHandshakeType = "agent_handshake"

AgentHandshakeType is the message type string for an AgentHandshake

View Source 
const BackendHandshakeType = "backend_handshake"

BackendHandshakeType is the message type string for a BackendHandshake

View Source 
const CheckRequestType = "check_request"

CheckRequestType is the message type string for check request.

View Source 
const DefaultSplayCoverage = 90.0

DefaultSplayCoverage is the default splay coverage for proxy check requests

View Source 
const EventFailingState = "failing"

EventFailingState indicates failing check result status

View Source 
const EventFlappingState = "flapping"

EventFlappingState indicates a rapid change in check result status

View Source 
const EventPassingState = "passing"

EventPassingState indicates successful check result status

View Source 
const GraphiteOutputMetricFormat = "graphite_plaintext"

GraphiteOutputMetricFormat is the accepted string to represent the output metric format of Graphite Plain Text

View Source 
const HookRequestType = "hook_request"

HookRequestType is the message type string for hook request.

View Source 
const InfluxDBOutputMetricFormat = "influxdb_line"

InfluxDBOutputMetricFormat is the accepted string to represent the output metric format of InfluxDB Line

View Source 
const NagiosOutputMetricFormat = "nagios_perfdata"

NagiosOutputMetricFormat is the accepted string to represent the output metric format of Nagios Perf Data

View Source 
const OpenTSDBOutputMetricFormat = "opentsdb_line"

OpenTSDBOutputMetricFormat is the accepted string to represent the output metric format of OpenTSDB Line

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 (
	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 (
	ErrInvalidLengthEnvironment = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEnvironment   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowError   = 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 (
	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 (
	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 (
	ErrInvalidLengthOrganization = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOrganization   = 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 (
	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 AssetNameRegex = regexp.MustCompile("^" + AssetNameRegexStr + "$")

AssetNameRegex used to validate name of asset

View Source 
var AssetNameRegexStr = `[a-z0-9\/\_\.\-]+`

AssetNameRegexStr used to validate name of asset

View Source 
var CheckHookRegex = regexp.MustCompile("^" + CheckHookRegexStr + "$")

CheckHookRegex used to validate type of check hook

View Source 
var CheckHookRegexStr = `([0-9]|[1-9][0-9]|1[0-9][0-9]|2[0-4][0-9]|25[0-5])`

CheckHookRegexStr used to validate type of check hook

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 (
	// RuleAllPerms all actions
	RuleAllPerms = []string{
		RulePermCreate,
		RulePermRead,
		RulePermUpdate,
		RulePermDelete,
	}
)
View Source 
var Severities = []string{"ok", "warning", "critical", "unknown", "non-zero"}

Severities used to validate type of check hook

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)

Functions

func ContextEnvironment 

func ContextEnvironment(ctx context.Context) string

ContextEnvironment returns the environment name injected in the context

func ContextOrganization 

func ContextOrganization(ctx context.Context) string

ContextOrganization returns the organization name injected in the context

func EnvVarsToMap 

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

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

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 GetEntitySubscription 

func GetEntitySubscription(entityID string) string

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

func SetContextFromResource 

func SetContextFromResource(ctx context.Context, r MultitenantResource) context.Context

SetContextFromResource takes a context and a multi-tenant resource, adds the environment and organization to the context, and returns the udpated context

func SilencedID 

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

SilencedID returns the canonical ID 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 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 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 {
	// Name is the name of the requested adhoc check.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"check"`
	// 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"`
}

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

func (m *AdhocRequest) GetName() 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) Size 

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

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.

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"`
}

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

type Asset 

type Asset struct {
	// Name is the unique identifier for an asset
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 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"`
	// Metadata is a set of key value pair associated with the asset
	Metadata map[string]string `` /* 140-byte string literal not displayed */
	// 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"`
	// Organization indicates to which org an asset belongs to
	Organization string `protobuf:"bytes,6,opt,name=organization,proto3" json:"organization,omitempty"`
}

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

func (a *Asset) GetEnvironment() string

GetEnvironment refers to the organization the check belongs to

func (*Asset) GetFilters 

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

func (*Asset) GetMetadata 

func (m *Asset) GetMetadata() map[string]string

func (*Asset) GetName 

func (m *Asset) GetName() string

func (*Asset) GetOrganization 

func (m *Asset) GetOrganization() string

func (*Asset) GetSha512 

func (m *Asset) GetSha512() string

func (*Asset) GetURL 

func (m *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) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) Reset 

func (m *Asset) Reset()

func (*Asset) Size 

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

func (*Asset) String 

func (m *Asset) String() string

func (*Asset) URIPath 

func (a *Asset) URIPath() string

URIPath returns the path component of a 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.

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"`
	// Environment indicates to which env a check belongs to
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,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"`
	// Name is the unique identifier for a check.
	Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	// Organization indicates to which org a check belongs to
	Organization string `protobuf:"bytes,8,opt,name=organization,proto3" json:"organization,omitempty"`
	// 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
	ProxyEntityID string `protobuf:"bytes,13,opt,name=proxy_entity_id,json=proxyEntityId,proto3" json:"proxy_entity_id"`
	// 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,omitempty"`
	// 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"`
	// ExtendedAttributes store serialized arbitrary JSON-encoded data
	ExtendedAttributes []byte `protobuf:"bytes,99,opt,name=ExtendedAttributes,proto3" 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 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) Get 

func (c *Check) Get(name string) (interface{}, error)

Get implements govaluate.Parameters

func (*Check) GetCheckHooks 

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

func (*Check) GetCommand 

func (m *Check) GetCommand() string

func (*Check) GetCron 

func (m *Check) GetCron() string

func (*Check) GetDuration 

func (m *Check) GetDuration() float64

func (*Check) GetEnvVars 

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

func (*Check) GetEnvironment 

func (m *Check) GetEnvironment() string

func (*Check) GetExecuted 

func (m *Check) GetExecuted() int64

func (*Check) GetExtendedAttributes 

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

func (*Check) GetHandlers 

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

func (*Check) GetHighFlapThreshold 

func (m *Check) GetHighFlapThreshold() uint32

func (*Check) GetHistory 

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

func (*Check) GetHooks 

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

func (*Check) GetInterval 

func (m *Check) GetInterval() uint32

func (*Check) GetIssued 

func (m *Check) GetIssued() int64

func (*Check) GetLastOK 

func (m *Check) GetLastOK() int64

func (*Check) GetLowFlapThreshold 

func (m *Check) GetLowFlapThreshold() uint32

func (*Check) GetName 

func (m *Check) GetName() string

func (*Check) GetOccurrences 

func (m *Check) GetOccurrences() int64

func (*Check) GetOccurrencesWatermark 

func (m *Check) GetOccurrencesWatermark() int64

func (*Check) GetOrganization 

func (m *Check) GetOrganization() string

func (*Check) GetOutput 

func (m *Check) GetOutput() string

func (*Check) GetOutputMetricFormat 

func (m *Check) GetOutputMetricFormat() string

func (*Check) GetOutputMetricHandlers 

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

func (*Check) GetProxyEntityID 

func (m *Check) GetProxyEntityID() string

func (*Check) GetProxyRequests 

func (m *Check) GetProxyRequests() *ProxyRequests

func (*Check) GetPublish 

func (m *Check) GetPublish() bool

func (*Check) GetRoundRobin 

func (m *Check) GetRoundRobin() bool

func (*Check) GetRuntimeAssets 

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

func (*Check) GetSilenced 

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

func (*Check) GetState 

func (m *Check) GetState() string

func (*Check) GetStatus 

func (m *Check) GetStatus() uint32

func (*Check) GetStdin 

func (m *Check) GetStdin() bool

func (*Check) GetSubdue 

func (m *Check) GetSubdue() *TimeWindowWhen

func (*Check) GetSubscriptions 

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

func (*Check) GetTimeout 

func (m *Check) GetTimeout() uint32

func (*Check) GetTotalStateChange 

func (m *Check) GetTotalStateChange() uint32

func (*Check) GetTtl 

func (m *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) ProtoMessage 

func (*Check) ProtoMessage()

func (*Check) Reset 

func (m *Check) Reset()

func (*Check) SetExtendedAttributes 

func (c *Check) SetExtendedAttributes(e []byte)

SetExtendedAttributes sets the serialized ExtendedAttributes of c.

func (*Check) Size 

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

func (*Check) String 

func (m *Check) String() string

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

func (c *Check) UnmarshalJSON(b []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*Check) Validate 

func (c *Check) Validate() error

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

type CheckConfig 

type CheckConfig struct {
	// Command is the command to be executed.
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// Environment indicates to which env a check belongs to
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,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"`
	// Name is the unique identifier for a check.
	Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	// Organization indicates to which org a check belongs to
	Organization string `protobuf:"bytes,8,opt,name=organization,proto3" json:"organization,omitempty"`
	// 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
	ProxyEntityID string `protobuf:"bytes,13,opt,name=proxy_entity_id,json=proxyEntityId,proto3" json:"proxy_entity_id"`
	// 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"`
}

CheckConfig is the specification of a check.

func FixtureCheckConfig 

func FixtureCheckConfig(id string) *CheckConfig

FixtureCheckConfig returns a fixture for a CheckConfig object.

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

func (c *CheckConfig) Get(name string) (interface{}, error)

Get implements govaluate.Parameters

func (*CheckConfig) GetCheckHooks 

func (m *CheckConfig) GetCheckHooks() []HookList

func (*CheckConfig) GetCommand 

func (m *CheckConfig) GetCommand() string

func (*CheckConfig) GetCron 

func (m *CheckConfig) GetCron() string

func (*CheckConfig) GetEnvVars 

func (m *CheckConfig) GetEnvVars() []string

func (*CheckConfig) GetEnvironment 

func (m *CheckConfig) GetEnvironment() string

func (*CheckConfig) GetExtendedAttributes 

func (m *CheckConfig) GetExtendedAttributes() []byte

func (*CheckConfig) GetHandlers 

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

func (*CheckConfig) GetHighFlapThreshold 

func (m *CheckConfig) GetHighFlapThreshold() uint32

func (*CheckConfig) GetInterval 

func (m *CheckConfig) GetInterval() uint32

func (*CheckConfig) GetLowFlapThreshold 

func (m *CheckConfig) GetLowFlapThreshold() uint32

func (*CheckConfig) GetName 

func (m *CheckConfig) GetName() string

func (*CheckConfig) GetOrganization 

func (m *CheckConfig) GetOrganization() string

func (*CheckConfig) GetOutputMetricFormat 

func (m *CheckConfig) GetOutputMetricFormat() string

func (*CheckConfig) GetOutputMetricHandlers 

func (m *CheckConfig) GetOutputMetricHandlers() []string

func (*CheckConfig) GetProxyEntityID 

func (m *CheckConfig) GetProxyEntityID() string

func (*CheckConfig) GetProxyRequests 

func (m *CheckConfig) GetProxyRequests() *ProxyRequests

func (*CheckConfig) GetPublish 

func (m *CheckConfig) GetPublish() bool

func (*CheckConfig) GetRoundRobin 

func (m *CheckConfig) GetRoundRobin() bool

func (*CheckConfig) GetRuntimeAssets 

func (m *CheckConfig) GetRuntimeAssets() []string

func (*CheckConfig) GetStdin 

func (m *CheckConfig) GetStdin() bool

func (*CheckConfig) GetSubdue 

func (m *CheckConfig) GetSubdue() *TimeWindowWhen

func (*CheckConfig) GetSubscriptions 

func (m *CheckConfig) GetSubscriptions() []string

func (*CheckConfig) GetTimeout 

func (m *CheckConfig) GetTimeout() uint32

func (*CheckConfig) GetTtl 

func (m *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) ProtoMessage 

func (*CheckConfig) ProtoMessage()

func (*CheckConfig) Reset 

func (m *CheckConfig) Reset()

func (*CheckConfig) SetExtendedAttributes 

func (c *CheckConfig) SetExtendedAttributes(e []byte)

SetExtendedAttributes sets the serialized ExtendedAttributes of c.

func (*CheckConfig) Size 

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

func (*CheckConfig) String 

func (m *CheckConfig) String() string

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

func (c *CheckConfig) UnmarshalJSON(b []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*CheckConfig) Validate 

func (c *CheckConfig) Validate() error

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

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"`
}

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

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"`
}

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

type Claims 

type Claims struct {
	jwt.StandardClaims
}

Claims represents the JWT claims

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"`
}

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

type Entity 

type Entity struct {
	ID               string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Class            string         `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
	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"`
	KeepaliveTimeout uint32         `protobuf:"varint,8,opt,name=keepalive_timeout,json=keepaliveTimeout,proto3" json:"keepalive_timeout"`
	Environment      string         `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	Organization     string         `protobuf:"bytes,10,opt,name=organization,proto3" json:"organization,omitempty"`
	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"`
}

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(id string) *Entity

FixtureEntity returns a testing fixture for an Entity object.

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

func (e *Entity) Get(name string) (interface{}, error)

Get implements govaluate.Parameters

func (*Entity) GetClass 

func (m *Entity) GetClass() string

func (*Entity) GetDeregister 

func (m *Entity) GetDeregister() bool

func (*Entity) GetDeregistration 

func (m *Entity) GetDeregistration() Deregistration

func (*Entity) GetEnvironment 

func (m *Entity) GetEnvironment() string

func (*Entity) GetExtendedAttributes 

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

func (*Entity) GetID 

func (m *Entity) GetID() string

func (*Entity) GetKeepaliveTimeout 

func (m *Entity) GetKeepaliveTimeout() uint32

func (*Entity) GetLastSeen 

func (m *Entity) GetLastSeen() int64

func (*Entity) GetOrganization 

func (m *Entity) GetOrganization() string

func (*Entity) GetRedact 

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

func (*Entity) GetSubscriptions 

func (m *Entity) GetSubscriptions() []string

func (*Entity) GetSystem 

func (m *Entity) GetSystem() System

func (*Entity) GetUser 

func (m *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) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) SetExtendedAttributes 

func (e *Entity) SetExtendedAttributes(b []byte)

SetExtendedAttributes sets the serialized ExtendedAttributes of the entity.

func (*Entity) Size 

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

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) URIPath 

func (e *Entity) URIPath() string

URIPath returns the path component of a Entity URI.

func (*Entity) Unmarshal 

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

func (*Entity) UnmarshalJSON 

func (e *Entity) UnmarshalJSON(b []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*Entity) Validate 

func (e *Entity) Validate() error

Validate returns an error if the entity is invalid.

type Environment 

type Environment struct {
	Description  string `protobuf:"bytes,1,opt,name=description,proto3" json:"description"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Organization string `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
}

Environment represents a Sensu environment in RBAC

func FixtureEnvironment 

func FixtureEnvironment(name string) *Environment

FixtureEnvironment returns a mocked environment.

func NewPopulatedEnvironment 

func NewPopulatedEnvironment(r randyEnvironment, easy bool) *Environment

func (*Environment) Descriptor 

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

func (*Environment) Equal 

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

func (*Environment) GetDescription 

func (m *Environment) GetDescription() string

func (*Environment) GetEnvironment 

func (e *Environment) GetEnvironment() string

GetEnvironment gets the Evironment that e belongs to (itself).

func (*Environment) GetName 

func (m *Environment) GetName() string

func (*Environment) GetOrganization 

func (m *Environment) GetOrganization() string

func (*Environment) Marshal 

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

func (*Environment) MarshalTo 

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

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) Reset 

func (m *Environment) Reset()

func (*Environment) Size 

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

func (*Environment) String 

func (m *Environment) String() string

func (*Environment) URIPath 

func (e *Environment) URIPath() string

URIPath returns the path component of a Environment URI.

func (*Environment) Unmarshal 

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

func (*Environment) Update 

func (e *Environment) Update(from *Environment, fields ...string) error

Update updates an Environment with selected fields.

func (*Environment) Validate 

func (e *Environment) Validate() error

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

type Error 

type Error struct {
	// Name is the unique identifier for an asset.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Message is the details associated with the error.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Component refers to the component in-which the error occurred.
	Component string `protobuf:"bytes,3,opt,name=component,proto3" json:"component,omitempty"`
	// Timestamp refers to the instant in-which the error occurred.
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp"`
	// Event refers to the event that was being processed when the error occurred.
	Event Event `protobuf:"bytes,5,opt,name=event" json:"event"`
}

Error describes an error captured while processing an event in Sensu's pipeline.

func FixtureError 

func FixtureError(name string, message string) *Error

FixtureError returns a testing fixture for an Error object.

func NewPopulatedError 

func NewPopulatedError(r randyError, easy bool) *Error

func (*Error) Descriptor 

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

func (*Error) Equal 

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

func (*Error) GetComponent 

func (m *Error) GetComponent() string

func (*Error) GetEnvironment 

func (perr *Error) GetEnvironment() string

GetEnvironment returns the environmen the entity is associated with.

func (*Error) GetEvent 

func (m *Error) GetEvent() Event

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetName 

func (m *Error) GetName() string

func (*Error) GetOrganization 

func (perr *Error) GetOrganization() string

GetOrganization returns the organization the entity is associated with.

func (*Error) GetTimestamp 

func (m *Error) GetTimestamp() int64

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

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 ...
	Metrics *Metrics `protobuf:"bytes,4,opt,name=metrics" json:"metrics,omitempty"`
	// Silenced is a list of silenced entry ids (subscription and check name)
	Silenced []string `protobuf:"bytes,5,rep,name=silenced" json:"silenced,omitempty"`
	// Hooks describes the results of multiple hooks; if event is associated to hook execution.
	Hooks []*Hook `protobuf:"bytes,6,rep,name=hooks" json:"hooks,omitempty"`
}

An Event is the encapsulating type sent across the Sensu websocket transport.

func FixtureEvent 

func FixtureEvent(entityID, checkID string) *Event

FixtureEvent returns a testing fixutre for an Event object.

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

func (e *Event) Get(name string) (interface{}, error)

Get implements govaluate.Parameters

func (*Event) GetCheck 

func (m *Event) GetCheck() *Check

func (*Event) GetEntity 

func (m *Event) GetEntity() *Entity

func (*Event) GetHooks 

func (m *Event) GetHooks() []*Hook

func (*Event) GetMetrics 

func (m *Event) GetMetrics() *Metrics

func (*Event) GetSilenced 

func (m *Event) GetSilenced() []string

func (*Event) GetTimestamp 

func (m *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) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) URIPath 

func (e *Event) URIPath() string

URIPath returns the path component of a Event URI.

func (*Event) Unmarshal 

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

func (*Event) UnmarshalJSON 

func (e *Event) UnmarshalJSON(b []byte) error

UnmarshalJSON ...

func (*Event) Validate 

func (e *Event) Validate() error

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

type EventFilter 

type EventFilter struct {
	// Name is the unique identifier for a filter
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Action specifies to allow/deny events to continue through the pipeline
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// Statements is an array of boolean expressions that are &&'d together
	// to determine if the event matches this filter.
	Statements []string `protobuf:"bytes,3,rep,name=statements" json:"statements"`
	// Environment indicates to which env a filter belongs to
	Environment string `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
	// Organization indicates to which org a filter belongs to
	Organization string `protobuf:"bytes,5,opt,name=organization,proto3" json:"organization,omitempty"`
	// When indicates a TimeWindowWhen that a filter uses to filter by days & times
	When *TimeWindowWhen `protobuf:"bytes,6,opt,name=when" json:"when,omitempty"`
}

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 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 (m *EventFilter) GetAction() string

func (*EventFilter) GetEnvironment 

func (m *EventFilter) GetEnvironment() string

func (*EventFilter) GetName 

func (m *EventFilter) GetName() string

func (*EventFilter) GetOrganization 

func (m *EventFilter) GetOrganization() string

func (*EventFilter) GetStatements 

func (m *EventFilter) GetStatements() []string

func (*EventFilter) GetWhen 

func (m *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) ProtoMessage 

func (*EventFilter) ProtoMessage()

func (*EventFilter) Reset 

func (m *EventFilter) Reset()

func (*EventFilter) Size 

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

func (*EventFilter) String 

func (m *EventFilter) String() string

func (*EventFilter) URIPath 

func (f *EventFilter) URIPath() string

URIPath returns the path component of a 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.

type Extension 

type Extension struct {
	// Name is the unique identifier for an extension.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,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"`
	// Organization indicates which organization an extension belongs to.
	Organization string `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
}

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

func (e *Extension) GetEnvironment() string

GetEnvironment gets the environment for the extension. For extensions, the environment is always '*'.

func (*Extension) GetName 

func (m *Extension) GetName() string

func (*Extension) GetOrganization 

func (m *Extension) GetOrganization() string

func (*Extension) GetURL 

func (m *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) ProtoMessage 

func (*Extension) ProtoMessage()

func (*Extension) Reset 

func (m *Extension) Reset()

func (*Extension) Size 

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

func (*Extension) String 

func (m *Extension) String() string

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.

type Handler 

type Handler struct {
	// Name is the unique identifier for a handler.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,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"`
	// Environment indicates to which env a handler belongs to
	Environment string `protobuf:"bytes,10,opt,name=environment,proto3" json:"environment,omitempty"`
	// Organization indicates to which org a handler belongs to
	Organization string `protobuf:"bytes,11,opt,name=organization,proto3" json:"organization,omitempty"`
}

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 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 (m *Handler) GetCommand() string

func (*Handler) GetEnvVars 

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

func (*Handler) GetEnvironment 

func (m *Handler) GetEnvironment() string

func (*Handler) GetFilters 

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

func (*Handler) GetHandlers 

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

func (*Handler) GetMutator 

func (m *Handler) GetMutator() string

func (*Handler) GetName 

func (m *Handler) GetName() string

func (*Handler) GetOrganization 

func (m *Handler) GetOrganization() string

func (*Handler) GetSocket 

func (m *Handler) GetSocket() *HandlerSocket

func (*Handler) GetTimeout 

func (m *Handler) GetTimeout() uint32

func (*Handler) GetType 

func (m *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) ProtoMessage 

func (*Handler) ProtoMessage()

func (*Handler) Reset 

func (m *Handler) Reset()

func (*Handler) Size 

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

func (*Handler) String 

func (m *Handler) String() string

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.

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"`
}

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

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"`
}

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

type HookConfig 

type HookConfig struct {
	// Name is the unique identifier for a hook
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,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"`
	// Environment indicates to which env a hook belongs to
	Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"`
	// Organization indicates to which org a hook belongs to
	Organization string `protobuf:"bytes,6,opt,name=organization,proto3" json:"organization,omitempty"`
}

HookConfig is the specification of a hook

func FixtureHookConfig 

func FixtureHookConfig(id string) *HookConfig

FixtureHookConfig returns a fixture for a HookConfig object.

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 (m *HookConfig) GetCommand() string

func (*HookConfig) GetEnvironment 

func (m *HookConfig) GetEnvironment() string

func (*HookConfig) GetName 

func (m *HookConfig) GetName() string

func (*HookConfig) GetOrganization 

func (m *HookConfig) GetOrganization() string

func (*HookConfig) GetStdin 

func (m *HookConfig) GetStdin() bool

func (*HookConfig) GetTimeout 

func (m *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) ProtoMessage 

func (*HookConfig) ProtoMessage()

func (*HookConfig) Reset 

func (m *HookConfig) Reset()

func (*HookConfig) Size 

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

func (*HookConfig) String 

func (m *HookConfig) String() string

func (*HookConfig) URIPath 

func (c *HookConfig) URIPath() string

URIPath returns the path component of a HookConfig 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.

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"`
}

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.

type KeepaliveRecord 

type KeepaliveRecord struct {
	Environment  string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	Organization string `protobuf:"bytes,2,opt,name=organization,proto3" json:"organization,omitempty"`
	EntityID     string `protobuf:"bytes,3,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	Time         int64  `protobuf:"varint,4,opt,name=time,proto3" json:"time"`
}

A KeepaliveRecord is a tuple of an Entity ID 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 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) GetEntityID 

func (m *KeepaliveRecord) GetEntityID() string

func (*KeepaliveRecord) GetEnvironment 

func (m *KeepaliveRecord) GetEnvironment() string

func (*KeepaliveRecord) GetOrganization 

func (m *KeepaliveRecord) GetOrganization() string

func (*KeepaliveRecord) GetTime 

func (m *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) 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) Unmarshal 

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

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"`
}

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

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"`
}

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

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"`
}

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.

type MultitenantResource 

type MultitenantResource interface {
	GetOrganization() string
	GetEnvironment() string
}

MultitenantResource is a object that belongs to an organization

type Mutator 

type Mutator struct {
	// Name is the unique identifier for a mutator.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,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"`
	// Environment indicates to which env a mutator belongs to
	Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"`
	// Organization specifies the organization to which the mutator belongs.
	Organization string `protobuf:"bytes,6,opt,name=organization,proto3" json:"organization,omitempty"`
}

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 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 (m *Mutator) GetCommand() string

func (*Mutator) GetEnvVars 

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

func (*Mutator) GetEnvironment 

func (m *Mutator) GetEnvironment() string

func (*Mutator) GetName 

func (m *Mutator) GetName() string

func (*Mutator) GetOrganization 

func (m *Mutator) GetOrganization() string

func (*Mutator) GetTimeout 

func (m *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) ProtoMessage 

func (*Mutator) ProtoMessage()

func (*Mutator) Reset 

func (m *Mutator) Reset()

func (*Mutator) Size 

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

func (*Mutator) String 

func (m *Mutator) String() string

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.

type Network 

type Network struct {
	Interfaces []NetworkInterface `protobuf:"bytes,1,rep,name=interfaces" json:"interfaces"`
}

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

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"`
}

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

type Organization 

type Organization struct {
	// Description is more information for an organization.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description"`
	// Name is the unique identifier for an organization.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
}

Organization represents a Sensu organization in RBAC

func FixtureOrganization 

func FixtureOrganization(name string) *Organization

FixtureOrganization returns a mocked organization

func NewPopulatedOrganization 

func NewPopulatedOrganization(r randyOrganization, easy bool) *Organization

func (*Organization) Descriptor 

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

func (*Organization) Equal 

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

func (*Organization) GetDescription 

func (m *Organization) GetDescription() string

func (*Organization) GetName 

func (m *Organization) GetName() string

func (*Organization) Marshal 

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

func (*Organization) MarshalTo 

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

func (*Organization) ProtoMessage 

func (*Organization) ProtoMessage()

func (*Organization) Reset 

func (m *Organization) Reset()

func (*Organization) Size 

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

func (*Organization) String 

func (m *Organization) String() string

func (*Organization) URIPath 

func (o *Organization) URIPath() string

URIPath returns the path component of a Organization URI.

func (*Organization) Unmarshal 

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

func (*Organization) Validate 

func (o *Organization) Validate() error

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

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"`
}

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

type Queue 

type Queue interface {
	// Enqueue adds a new item to the queue. It returns any error that
	// was encountered in doing so, or if the context is cancelled.
	Enqueue(ctx context.Context, value string) error

	// Dequeue gets an Item from the queue. It returns the Item and any
	// error encountered, or if the context is cancelled.
	Dequeue(ctx context.Context) (QueueItem, error)
}

Queue is the interface of a queue. Queue's methods are atomic and goroutine-safe.

type QueueGetter 

type QueueGetter interface {
	GetQueue(path ...string) Queue
}

QueueGetter is a type that provides a way to get a Queue.

type QueueItem 

type QueueItem interface {
	// Value is the item's underlying value.
	Value() string

	// Ack acks the item. The item will no longer be stored.
	Ack(context.Context) error

	// Nack nacks the item. The item will return to the Queue.
	Nack(context.Context) error
}

QueueItem represents an item retrieved from a Queue.

type Resource 

type Resource interface {
	// 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 Ring 

type Ring interface {
	// Add adds an item to the ring. It returns a non-nil error if the
	// operation failed, or the context is cancelled before the operation
	// completed.
	Add(ctx context.Context, value string) error

	// Remove removes an item from the ring. It returns a non-nil error if the
	// operation failed, or the context is cancelled before the operation
	// completed.
	Remove(ctx context.Context, value string) error

	// Next gets the next item in the Ring. The other items in the Ring will
	// all be returned by subsequent calls to Next before this item is
	// returned again. Next returns the selected value, and an error indicating
	// if the operation failed, or if the context was cancelled.
	Next(context.Context) (string, error)

	// Peek gets the next item in the Ring, but does not advance the iteration.
	Peek(context.Context) (string, error)
}

Ring is the interface of a ring. Ring's methods are atomic and goroutine-safe.

type RingGetter 

type RingGetter interface {
	// GetRing gets a named Ring.
	GetRing(path ...string) Ring
}

RingGetter provides a way to get a Ring.

type Role 

type Role struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Rules []Rule `protobuf:"bytes,2,rep,name=rules" json:"rules"`
}

Role describes set of rules

func FixtureRole 

func FixtureRole(name, org, env string) *Role

FixtureRole returns a partial role

func NewPopulatedRole 

func NewPopulatedRole(r randyRbac, easy bool) *Role

func (*Role) Descriptor 

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

func (*Role) Equal 

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

func (*Role) GetName 

func (m *Role) GetName() string

func (*Role) GetRules 

func (m *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) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) Reset 

func (m *Role) Reset()

func (*Role) Size 

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

func (*Role) String 

func (m *Role) String() string

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 returns an error if the role is invalid.

type Rule 

type Rule struct {
	Type         string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Environment  string   `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Organization string   `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
	Permissions  []string `protobuf:"bytes,4,rep,name=permissions" json:"permissions"`
}

Rule maps permissions to a given type

func FixtureRule 

func FixtureRule(org, env string) *Rule

FixtureRule returns a partial rule

func FixtureRuleWithPerms 

func FixtureRuleWithPerms(T string, perms ...string) Rule

FixtureRuleWithPerms returns a partial rule with perms applied

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

func (m *Rule) GetEnvironment() string

func (*Rule) GetOrganization 

func (m *Rule) GetOrganization() string

func (*Rule) GetPermissions 

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

func (*Rule) GetType 

func (m *Rule) GetType() 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) 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) Validate 

func (r *Rule) Validate() error

Validate returns an error if the rule is invalid.

type Silenced 

type Silenced struct {
	// ID is the combination of subscription and check name (subscription:checkname)
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,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"`
	// Organization indicates to which org a silenced entry belongs to.
	Organization string `protobuf:"bytes,8,opt,name=organization,proto3" json:"organization,omitempty"`
	// Environment indicates which env a silenced entry belongs to.
	Environment string `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	// Begin is a timestamp at which the silenced entry takes effect.
	Begin int64 `protobuf:"varint,10,opt,name=begin,proto3" json:"begin"`
}

Silenced is the representation of a silence entry.

func FixtureSilenced 

func FixtureSilenced(id string) *Silenced

FixtureSilenced returns a testing fixutre for a Silenced event struct.

func NewPopulatedSilenced 

func NewPopulatedSilenced(r randySilenced, easy bool) *Silenced

func (*Silenced) Descriptor 

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

func (*Silenced) Equal 

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

func (*Silenced) GetBegin 

func (m *Silenced) GetBegin() int64

func (*Silenced) GetCheck 

func (m *Silenced) GetCheck() string

func (*Silenced) GetCreator 

func (m *Silenced) GetCreator() string

func (*Silenced) GetEnvironment 

func (m *Silenced) GetEnvironment() string

func (*Silenced) GetExpire 

func (m *Silenced) GetExpire() int64

func (*Silenced) GetExpireOnResolve 

func (m *Silenced) GetExpireOnResolve() bool

func (*Silenced) GetID 

func (m *Silenced) GetID() string

func (*Silenced) GetOrganization 

func (m *Silenced) GetOrganization() string

func (*Silenced) GetReason 

func (m *Silenced) GetReason() string

func (*Silenced) GetSubscription 

func (m *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) ProtoMessage 

func (*Silenced) ProtoMessage()

func (*Silenced) Reset 

func (m *Silenced) Reset()

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

func (m *Silenced) String() string

func (*Silenced) URIPath 

func (s *Silenced) URIPath() string

URIPath returns the path component of a Silenced 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.

type StatusMap 

type StatusMap map[string]bool

StatusMap is a map of backend component names to their current status info.

func (StatusMap) Healthy 

func (s StatusMap) Healthy() bool

Healthy returns true if the StatsMap shows all healthy indicators; false otherwise.

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"`
}

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

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"`
}

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

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

ToTLSConfig outputs a tls.Config from TLSOptions

func (*TLSOptions) Unmarshal 

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

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"`
}

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

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"`
}

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.

type TimeWindowWhen 

type TimeWindowWhen struct {
	// Days is a hash of days
	Days TimeWindowDays `protobuf:"bytes,1,opt,name=days" json:"days"`
}

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.

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"`
}

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.

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"`
	Roles    []string `protobuf:"bytes,3,rep,name=roles" json:"roles,omitempty"`
	Disabled bool     `protobuf:"varint,4,opt,name=disabled,proto3" json:"disabled"`
}

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

func (m *User) GetPassword() string

func (*User) GetRoles 

func (m *User) GetRoles() []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) Size 

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

func (*User) String 

func (m *User) String() string

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.

type Wrapper 

type Wrapper struct {
	// Type is the fully-qualified type name, e.g.
	// github.com/sensu/sensu-go/types.Check,
	// OR, a short-hand name that assumes a package path of
	// github.com/sensu/sensu-go/types.
	Type string `json:"type"`

	// Value is a valid Resource of concrete type Type.
	Value Resource `json:"spec"`
}

Wrapper is a generic wrapper, with a type field for distinguishing its contents.

func WrapResource 

func WrapResource(r Resource) Wrapper

WrapResource uses reflection on a Resource to wrap it in a Wrapper

func (*Wrapper) UnmarshalJSON 

func (w *Wrapper) UnmarshalJSON(b []byte) error

UnmarshalJSON ...

Source Files

View all Source files

Directories

Path Synopsis

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.