validate

Documentation

Index

• Variables
• func AttachNotificationRequest(req *protos.AttachNotificationRequest) error
• func AttachPipelineCommand(cmd *protos.AttachPipelineCommand) error
• func AttachPipelineRequest(req *protos.AttachPipelineRequest) error
• func Audience(audience *protos.Audience) error
• func BusEvent(req *protos.BusEvent) error
• func ClientInfo(clientInfo *protos.ClientInfo) error
• func CreateNotificationRequest(req *protos.CreateNotificationRequest) error
• func CreatePipelineRequest(req *protos.CreatePipelineRequest) error
• func DeleteAudienceRequest(req *protos.DeleteAudienceRequest) error
• func DeleteNotificationRequest(req *protos.DeleteNotificationRequest) error
• func DeletePipelineRequest(req *protos.DeletePipelineRequest) error
• func DeleteServiceRequest(req *protos.DeleteServiceRequest) error
• func DetachNotificationRequest(req *protos.DetachNotificationRequest) error
• func DetachPipelineRequest(req *protos.DetachPipelineRequest) error
• func ErrEmptyField(field string) error
• func ErrInvalidCharacters(field string) error
• func ErrNilField(field string) error
• func ErrUnsetEnum(field string) error
• func GetAllRequest(req *protos.GetAllRequest) error
• func GetNotificationRequest(req *protos.GetNotificationRequest) error
• func GetPipelineRequest(req *protos.GetPipelineRequest) error
• func GetPipelinesRequest(req *protos.GetPipelinesRequest) error
• func GetSchemaRequest(r *protos.GetSchemaRequest) error
• func HeartbeatRequest(req *protos.HeartbeatRequest) error
• func KVCreateHTTPRequest(r *protos.KVCreateHTTPRequest) error
• func KVInstruction(i *protos.KVInstruction) error
• func KVObject(obj *protos.KVObject, checkTimestamps, checkValue bool) error
• func KVRequest(r *protos.KVRequest) error
• func KVUpdateHTTPRequest(r *protos.KVUpdateHTTPRequest) error
• func Metric(metric *protos.Metric) error
• func MetricsRequest(req *protos.MetricsRequest) error
• func NewAudienceRequest(req *protos.NewAudienceRequest) error
• func PausePipelineRequest(req *protos.PausePipelineRequest) error
• func Pipeline(p *protos.Pipeline, requireId bool) error
• func PipelineStep(s *protos.PipelineStep) error
• func RegisterRequest(req *protos.RegisterRequest) error
• func ResumePipelineRequest(req *protos.ResumePipelineRequest) error
• func SendSchemaRequest(r *protos.SendSchemaRequest) error
• func StartTailRequest(r *protos.TailRequest) error
• func StopTailRequest(r *protos.TailRequest) error
• func TailResponse(r *protos.TailResponse) error
• func UpdateNotificationRequest(req *protos.UpdateNotificationRequest) error
• func UpdatePipelineRequest(req *protos.UpdatePipelineRequest) error

Variables

var (
	ErrNilInput          = errors.New("request cannot be nil")
	ValidCharactersRegex = regexp.MustCompile(`^[a-zA-Z0-9_-]+$`)
)

Functions

func AttachNotificationRequest

func AttachNotificationRequest(req *protos.AttachNotificationRequest) error

func AttachPipelineCommand

func AttachPipelineCommand(cmd *protos.AttachPipelineCommand) error

func AttachPipelineRequest

func AttachPipelineRequest(req *protos.AttachPipelineRequest) error

func Audience

func Audience(audience *protos.Audience) error

func BusEvent

func BusEvent(req *protos.BusEvent) error

func ClientInfo

func ClientInfo(clientInfo *protos.ClientInfo) error

func CreateNotificationRequest

func CreateNotificationRequest(req *protos.CreateNotificationRequest) error

func CreatePipelineRequest

func CreatePipelineRequest(req *protos.CreatePipelineRequest) error

func DeleteAudienceRequest

func DeleteAudienceRequest(req *protos.DeleteAudienceRequest) error

func DeleteNotificationRequest

func DeleteNotificationRequest(req *protos.DeleteNotificationRequest) error

func DeletePipelineRequest

func DeletePipelineRequest(req *protos.DeletePipelineRequest) error

func DeleteServiceRequest

func DeleteServiceRequest(req *protos.DeleteServiceRequest) error

func DetachNotificationRequest

func DetachNotificationRequest(req *protos.DetachNotificationRequest) error

func DetachPipelineRequest

func DetachPipelineRequest(req *protos.DetachPipelineRequest) error

func ErrEmptyField

func ErrEmptyField(field string) error

func ErrInvalidCharacters

func ErrInvalidCharacters(field string) error

func ErrNilField

func ErrNilField(field string) error

func ErrUnsetEnum

func ErrUnsetEnum(field string) error

func GetAllRequest

func GetAllRequest(req *protos.GetAllRequest) error

func GetNotificationRequest

func GetNotificationRequest(req *protos.GetNotificationRequest) error

func GetPipelineRequest

func GetPipelineRequest(req *protos.GetPipelineRequest) error

func GetPipelinesRequest

func GetPipelinesRequest(req *protos.GetPipelinesRequest) error

func GetSchemaRequest

func GetSchemaRequest(r *protos.GetSchemaRequest) error

func HeartbeatRequest

func HeartbeatRequest(req *protos.HeartbeatRequest) error

func KVCreateHTTPRequest

func KVCreateHTTPRequest(r *protos.KVCreateHTTPRequest) error

func KVInstruction

func KVInstruction(i *protos.KVInstruction) error

func KVObject

func KVObject(obj *protos.KVObject, checkTimestamps, checkValue bool) error

KVObject validates a KVObject; checkTimestamps is exposed because in some cases we might not have a TS yet (ie. Create KV)

func KVRequest

func KVRequest(r *protos.KVRequest) error

func KVUpdateHTTPRequest

func KVUpdateHTTPRequest(r *protos.KVUpdateHTTPRequest) error

func Metric

func Metric(metric *protos.Metric) error

func MetricsRequest

func MetricsRequest(req *protos.MetricsRequest) error

func NewAudienceRequest

func NewAudienceRequest(req *protos.NewAudienceRequest) error

func PausePipelineRequest

func PausePipelineRequest(req *protos.PausePipelineRequest) error

func Pipeline

func Pipeline(p *protos.Pipeline, requireId bool) error

func PipelineStep

func PipelineStep(s *protos.PipelineStep) error

func RegisterRequest

func RegisterRequest(req *protos.RegisterRequest) error

func ResumePipelineRequest

func ResumePipelineRequest(req *protos.ResumePipelineRequest) error

func SendSchemaRequest

func SendSchemaRequest(r *protos.SendSchemaRequest) error

func StartTailRequest

func StartTailRequest(r *protos.TailRequest) error

func StopTailRequest

func StopTailRequest(r *protos.TailRequest) error

func TailResponse

func TailResponse(r *protos.TailResponse) error

func UpdateNotificationRequest

func UpdateNotificationRequest(req *protos.UpdateNotificationRequest) error

func UpdatePipelineRequest

func UpdatePipelineRequest(req *protos.UpdatePipelineRequest) error