internal

package
v0.0.0-...-6f76032 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ArchiveFormat_name = map[int32]string{
	0: "ARCHIVEUNKNOWN",
	1: "ARCHIVEAUTO",
	2: "ARCHIVETARGZ",
	3: "ARCHIVEZIP",
}
View Source 
var ArchiveFormat_value = map[string]int32{
	"ARCHIVEUNKNOWN": 0,
	"ARCHIVEAUTO":    1,
	"ARCHIVETARGZ":   2,
	"ARCHIVEZIP":     3,
}
View Source 
var FilterSpecifications_name = map[int32]string{
	0: "ALL",
	1: "RUNNING",
	2: "TERMINATED",
	3: "FAILED",
	4: "SUCCESSFUL",
}
View Source 
var FilterSpecifications_value = map[string]int32{
	"ALL":        0,
	"RUNNING":    1,
	"TERMINATED": 2,
	"FAILED":     3,
	"SUCCESSFUL": 4,
}
View Source 
var LogFormat_name = map[int32]string{
	0: "LOGFORMATUNKNOWN",
	1: "LOGFORMATDEFAULT",
	2: "LOGFORMATJSON",
	3: "LOGFORMATPLAIN",
}
View Source 
var LogFormat_value = map[string]int32{
	"LOGFORMATUNKNOWN": 0,
	"LOGFORMATDEFAULT": 1,
	"LOGFORMATJSON":    2,
	"LOGFORMATPLAIN":   3,
}
View Source 
var LoggingPayloadFormat_name = map[int32]string{
	0: "FORMATUNKNONW",
	1: "FORMATBSON",
	2: "FORMATJSON",
	3: "FORMATSTRING",
}
View Source 
var LoggingPayloadFormat_value = map[string]int32{
	"FORMATUNKNONW": 0,
	"FORMATBSON":    1,
	"FORMATJSON":    2,
	"FORMATSTRING":  3,
}
View Source 
var RawLoggerConfigFormat_name = map[int32]string{
	0: "RAWLOGGERCONFIGFORMATJSON",
	1: "RAWLOGGERCONFIGFORMATBSON",
	2: "RAWLOGGERCONFIGFORMATUNKNOWN",
}
View Source 
var RawLoggerConfigFormat_value = map[string]int32{
	"RAWLOGGERCONFIGFORMATJSON":    0,
	"RAWLOGGERCONFIGFORMATBSON":    1,
	"RAWLOGGERCONFIGFORMATUNKNOWN": 2,
}
View Source 
var SignalTriggerID_name = map[int32]string{
	0: "NONE",
	1: "CLEANTERMINATION",
}
View Source 
var SignalTriggerID_value = map[string]int32{
	"NONE":             0,
	"CLEANTERMINATION": 1,
}
View Source 
var Signals_name = map[int32]string{
	0: "UNKNOWN",
	1: "TERMINATE",
	2: "KILL",
	3: "HANGUP",
	4: "INIT",
	5: "USER1",
	6: "USER2",
	7: "ABRT",
}
View Source 
var Signals_value = map[string]int32{
	"UNKNOWN":   0,
	"TERMINATE": 1,
	"KILL":      2,
	"HANGUP":    3,
	"INIT":      4,
	"USER1":     5,
	"USER2":     6,
	"ABRT":      7,
}

Functions

func AttachService 

func AttachService(ctx context.Context, manager jasper.Manager, s *grpc.Server) error

AttachService attaches the given manager to the jasper GRPC server. This function eventually calls generated Protobuf code for registering the GRPC Jasper server with the given Manager.

func RegisterJasperProcessManagerServer 

func RegisterJasperProcessManagerServer(s *grpc.Server, srv JasperProcessManagerServer)

Types

type ArchiveFormat 

type ArchiveFormat int32
const (
	ArchiveFormat_ARCHIVEUNKNOWN ArchiveFormat = 0
	ArchiveFormat_ARCHIVEAUTO    ArchiveFormat = 1
	ArchiveFormat_ARCHIVETARGZ   ArchiveFormat = 2
	ArchiveFormat_ARCHIVEZIP     ArchiveFormat = 3
)

func ConvertArchiveFormat 

func ConvertArchiveFormat(format roptions.ArchiveFormat) ArchiveFormat

ConvertArchiveFormat takes a Jasper ArchiveFormat struct and returns an equivalent protobuf RPC ArchiveFormat struct. ConvertArchiveFormat is the inverse of (ArchiveFormat) Export().

func (ArchiveFormat) EnumDescriptor 

func (ArchiveFormat) EnumDescriptor() ([]byte, []int)

func (ArchiveFormat) Export 

func (format ArchiveFormat) Export() roptions.ArchiveFormat

Export takes a protobuf RPC ArchiveFormat struct and returns the analogous Jasper ArchiveFormat struct.

func (ArchiveFormat) String 

func (x ArchiveFormat) String() string

type ArchiveOptions 

type ArchiveOptions struct {
	ShouldExtract        bool          `protobuf:"varint,1,opt,name=should_extract,json=shouldExtract,proto3" json:"should_extract,omitempty"`
	Format               ArchiveFormat `protobuf:"varint,2,opt,name=format,proto3,enum=jasper.ArchiveFormat" json:"format,omitempty"`
	TargetPath           string        `protobuf:"bytes,3,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func ConvertArchiveOptions 

func ConvertArchiveOptions(opts roptions.Archive) *ArchiveOptions

ConvertArchiveOptions takes a Jasper ArchiveOptions struct and returns an equivalent protobuf RPC ArchiveOptions struct. ConvertArchiveOptions is the inverse of (ArchiveOptions) Export().

func (*ArchiveOptions) Descriptor 

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

func (ArchiveOptions) Export 

func (opts ArchiveOptions) Export() roptions.Archive

Export takes a protobuf RPC ArchiveOptions struct and returns the analogous Jasper ArchiveOptions struct.

func (*ArchiveOptions) GetFormat 

func (m *ArchiveOptions) GetFormat() ArchiveFormat

func (*ArchiveOptions) GetShouldExtract 

func (m *ArchiveOptions) GetShouldExtract() bool

func (*ArchiveOptions) GetTargetPath 

func (m *ArchiveOptions) GetTargetPath() string

func (*ArchiveOptions) ProtoMessage 

func (*ArchiveOptions) ProtoMessage()

func (*ArchiveOptions) Reset 

func (m *ArchiveOptions) Reset()

func (*ArchiveOptions) String 

func (m *ArchiveOptions) String() string

func (*ArchiveOptions) XXX_DiscardUnknown 

func (m *ArchiveOptions) XXX_DiscardUnknown()

func (*ArchiveOptions) XXX_Marshal 

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

func (*ArchiveOptions) XXX_Merge 

func (m *ArchiveOptions) XXX_Merge(src proto.Message)

func (*ArchiveOptions) XXX_Size 

func (m *ArchiveOptions) XXX_Size() int

func (*ArchiveOptions) XXX_Unmarshal 

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

type BaseOptions 

type BaseOptions struct {
	Level                *LogLevel      `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	Buffer               *BufferOptions `protobuf:"bytes,2,opt,name=buffer,proto3" json:"buffer,omitempty"`
	Format               LogFormat      `protobuf:"varint,3,opt,name=format,proto3,enum=jasper.LogFormat" json:"format,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*BaseOptions) Descriptor 

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

func (BaseOptions) Export 

func (opts BaseOptions) Export() options.BaseOptions

Export takes a protobuf RPC BaseOptions struct and returns the analogous Jasper BaseOptions struct.

func (*BaseOptions) GetBuffer 

func (m *BaseOptions) GetBuffer() *BufferOptions

func (*BaseOptions) GetFormat 

func (m *BaseOptions) GetFormat() LogFormat

func (*BaseOptions) GetLevel 

func (m *BaseOptions) GetLevel() *LogLevel

func (*BaseOptions) ProtoMessage 

func (*BaseOptions) ProtoMessage()

func (*BaseOptions) Reset 

func (m *BaseOptions) Reset()

func (*BaseOptions) String 

func (m *BaseOptions) String() string

func (*BaseOptions) XXX_DiscardUnknown 

func (m *BaseOptions) XXX_DiscardUnknown()

func (*BaseOptions) XXX_Marshal 

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

func (*BaseOptions) XXX_Merge 

func (m *BaseOptions) XXX_Merge(src proto.Message)

func (*BaseOptions) XXX_Size 

func (m *BaseOptions) XXX_Size() int

func (*BaseOptions) XXX_Unmarshal 

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

type BufferOptions 

type BufferOptions struct {
	Buffered             bool     `protobuf:"varint,1,opt,name=buffered,proto3" json:"buffered,omitempty"`
	Duration             int64    `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"`
	MaxSize              int64    `protobuf:"varint,3,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ConvertBufferOptions 

func ConvertBufferOptions(opts options.BufferOptions) *BufferOptions

ConvertBufferOptions takes a Jasper BufferOptions struct and returns an equivalent protobuf RPC BufferOptions struct. ConvertBufferOptions is the inverse of (*BufferOptions) Export().

func (*BufferOptions) Descriptor 

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

func (*BufferOptions) Export 

func (opts *BufferOptions) Export() options.BufferOptions

Export takes a protobuf RPC BufferOptions struct and returns the analogous Jasper BufferOptions struct.

func (*BufferOptions) GetBuffered 

func (m *BufferOptions) GetBuffered() bool

func (*BufferOptions) GetDuration 

func (m *BufferOptions) GetDuration() int64

func (*BufferOptions) GetMaxSize 

func (m *BufferOptions) GetMaxSize() int64

func (*BufferOptions) ProtoMessage 

func (*BufferOptions) ProtoMessage()

func (*BufferOptions) Reset 

func (m *BufferOptions) Reset()

func (*BufferOptions) String 

func (m *BufferOptions) String() string

func (*BufferOptions) XXX_DiscardUnknown 

func (m *BufferOptions) XXX_DiscardUnknown()

func (*BufferOptions) XXX_Marshal 

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

func (*BufferOptions) XXX_Merge 

func (m *BufferOptions) XXX_Merge(src proto.Message)

func (*BufferOptions) XXX_Size 

func (m *BufferOptions) XXX_Size() int

func (*BufferOptions) XXX_Unmarshal 

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

type BuildloggerURLs 

type BuildloggerURLs struct {
	Urls                 []string `protobuf:"bytes,1,rep,name=urls,proto3" json:"urls,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BuildloggerURLs) Descriptor 

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

func (*BuildloggerURLs) GetUrls 

func (m *BuildloggerURLs) GetUrls() []string

func (*BuildloggerURLs) ProtoMessage 

func (*BuildloggerURLs) ProtoMessage()

func (*BuildloggerURLs) Reset 

func (m *BuildloggerURLs) Reset()

func (*BuildloggerURLs) String 

func (m *BuildloggerURLs) String() string

func (*BuildloggerURLs) XXX_DiscardUnknown 

func (m *BuildloggerURLs) XXX_DiscardUnknown()

func (*BuildloggerURLs) XXX_Marshal 

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

func (*BuildloggerURLs) XXX_Merge 

func (m *BuildloggerURLs) XXX_Merge(src proto.Message)

func (*BuildloggerURLs) XXX_Size 

func (m *BuildloggerURLs) XXX_Size() int

func (*BuildloggerURLs) XXX_Unmarshal 

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

type CreateOptions 

type CreateOptions struct {
	Args                 []string          `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	WorkingDirectory     string            `protobuf:"bytes,2,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
	Environment          map[string]string `` /* 163-byte string literal not displayed */
	OverrideEnviron      bool              `protobuf:"varint,4,opt,name=override_environ,json=overrideEnviron,proto3" json:"override_environ,omitempty"`
	TimeoutSeconds       int64             `protobuf:"varint,5,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	Tags                 []string          `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	OnSuccess            []*CreateOptions  `protobuf:"bytes,7,rep,name=on_success,json=onSuccess,proto3" json:"on_success,omitempty"`
	OnFailure            []*CreateOptions  `protobuf:"bytes,8,rep,name=on_failure,json=onFailure,proto3" json:"on_failure,omitempty"`
	OnTimeout            []*CreateOptions  `protobuf:"bytes,9,rep,name=on_timeout,json=onTimeout,proto3" json:"on_timeout,omitempty"`
	Output               *OutputOptions    `protobuf:"bytes,10,opt,name=output,proto3" json:"output,omitempty"`
	StandardInputBytes   []byte            `protobuf:"bytes,11,opt,name=standard_input_bytes,json=standardInputBytes,proto3" json:"standard_input_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func ConvertCreateOptions 

func ConvertCreateOptions(opts *options.Create) (*CreateOptions, error)

ConvertCreateOptions takes a Jasper CreateOptions struct and returns an equivalent protobuf RPC *CreateOptions struct. ConvertCreateOptions is the inverse of (*CreateOptions) Export(). It is not safe to concurrently access the converted Jasper CreateOptions and the returned RPC CreateOptions.

func (*CreateOptions) Descriptor 

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

func (*CreateOptions) Export 

func (opts *CreateOptions) Export() (*options.Create, error)

Export takes a protobuf RPC CreateOptions struct and returns the analogous Jasper CreateOptions struct. It is not safe to concurrently access the exported RPC CreateOptions and the returned Jasper CreateOptions.

func (*CreateOptions) GetArgs 

func (m *CreateOptions) GetArgs() []string

func (*CreateOptions) GetEnvironment 

func (m *CreateOptions) GetEnvironment() map[string]string

func (*CreateOptions) GetOnFailure 

func (m *CreateOptions) GetOnFailure() []*CreateOptions

func (*CreateOptions) GetOnSuccess 

func (m *CreateOptions) GetOnSuccess() []*CreateOptions

func (*CreateOptions) GetOnTimeout 

func (m *CreateOptions) GetOnTimeout() []*CreateOptions

func (*CreateOptions) GetOutput 

func (m *CreateOptions) GetOutput() *OutputOptions

func (*CreateOptions) GetOverrideEnviron 

func (m *CreateOptions) GetOverrideEnviron() bool

func (*CreateOptions) GetStandardInputBytes 

func (m *CreateOptions) GetStandardInputBytes() []byte

func (*CreateOptions) GetTags 

func (m *CreateOptions) GetTags() []string

func (*CreateOptions) GetTimeoutSeconds 

func (m *CreateOptions) GetTimeoutSeconds() int64

func (*CreateOptions) GetWorkingDirectory 

func (m *CreateOptions) GetWorkingDirectory() string

func (*CreateOptions) ProtoMessage 

func (*CreateOptions) ProtoMessage()

func (*CreateOptions) Reset 

func (m *CreateOptions) Reset()

func (*CreateOptions) String 

func (m *CreateOptions) String() string

func (*CreateOptions) XXX_DiscardUnknown 

func (m *CreateOptions) XXX_DiscardUnknown()

func (*CreateOptions) XXX_Marshal 

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

func (*CreateOptions) XXX_Merge 

func (m *CreateOptions) XXX_Merge(src proto.Message)

func (*CreateOptions) XXX_Size 

func (m *CreateOptions) XXX_Size() int

func (*CreateOptions) XXX_Unmarshal 

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

type DefaultLoggerOptions 

type DefaultLoggerOptions struct {
	Prefix               string       `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Base                 *BaseOptions `protobuf:"bytes,2,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DefaultLoggerOptions) Descriptor 

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

func (DefaultLoggerOptions) Export 

func (opts DefaultLoggerOptions) Export() options.LoggerProducer

Export takes a protobuf RPC DefaultLoggerOptions struct and returns the analogous Jasper options.LoggerProducer.

func (*DefaultLoggerOptions) GetBase 

func (m *DefaultLoggerOptions) GetBase() *BaseOptions

func (*DefaultLoggerOptions) GetPrefix 

func (m *DefaultLoggerOptions) GetPrefix() string

func (*DefaultLoggerOptions) ProtoMessage 

func (*DefaultLoggerOptions) ProtoMessage()

func (*DefaultLoggerOptions) Reset 

func (m *DefaultLoggerOptions) Reset()

func (*DefaultLoggerOptions) String 

func (m *DefaultLoggerOptions) String() string

func (*DefaultLoggerOptions) XXX_DiscardUnknown 

func (m *DefaultLoggerOptions) XXX_DiscardUnknown()

func (*DefaultLoggerOptions) XXX_Marshal 

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

func (*DefaultLoggerOptions) XXX_Merge 

func (m *DefaultLoggerOptions) XXX_Merge(src proto.Message)

func (*DefaultLoggerOptions) XXX_Size 

func (m *DefaultLoggerOptions) XXX_Size() int

func (*DefaultLoggerOptions) XXX_Unmarshal 

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

type DownloadInfo 

type DownloadInfo struct {
	Url                  string          `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Path                 string          `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ArchiveOpts          *ArchiveOptions `protobuf:"bytes,3,opt,name=archive_opts,json=archiveOpts,proto3" json:"archive_opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func ConvertDownloadOptions 

func ConvertDownloadOptions(opts roptions.Download) *DownloadInfo

ConvertDownloadOptions takes an remote.Download struct and returns an equivalent protobuf RPC DownloadInfo struct. ConvertDownloadOptions is the inverse of (*DownloadInfo) Export().

func (*DownloadInfo) Descriptor 

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

func (*DownloadInfo) Export 

func (opts *DownloadInfo) Export() roptions.Download

Export takes a protobuf RPC DownloadInfo struct and returns the analogous options.Download struct.

func (*DownloadInfo) GetArchiveOpts 

func (m *DownloadInfo) GetArchiveOpts() *ArchiveOptions

func (*DownloadInfo) GetPath 

func (m *DownloadInfo) GetPath() string

func (*DownloadInfo) GetUrl 

func (m *DownloadInfo) GetUrl() string

func (*DownloadInfo) ProtoMessage 

func (*DownloadInfo) ProtoMessage()

func (*DownloadInfo) Reset 

func (m *DownloadInfo) Reset()

func (*DownloadInfo) String 

func (m *DownloadInfo) String() string

func (*DownloadInfo) XXX_DiscardUnknown 

func (m *DownloadInfo) XXX_DiscardUnknown()

func (*DownloadInfo) XXX_Marshal 

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

func (*DownloadInfo) XXX_Merge 

func (m *DownloadInfo) XXX_Merge(src proto.Message)

func (*DownloadInfo) XXX_Size 

func (m *DownloadInfo) XXX_Size() int

func (*DownloadInfo) XXX_Unmarshal 

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

type EventName 

type EventName struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventName) Descriptor 

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

func (*EventName) GetValue 

func (m *EventName) GetValue() string

func (*EventName) ProtoMessage 

func (*EventName) ProtoMessage()

func (*EventName) Reset 

func (m *EventName) Reset()

func (*EventName) String 

func (m *EventName) String() string

func (*EventName) XXX_DiscardUnknown 

func (m *EventName) XXX_DiscardUnknown()

func (*EventName) XXX_Marshal 

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

func (*EventName) XXX_Merge 

func (m *EventName) XXX_Merge(src proto.Message)

func (*EventName) XXX_Size 

func (m *EventName) XXX_Size() int

func (*EventName) XXX_Unmarshal 

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

type FileLoggerOptions 

type FileLoggerOptions struct {
	Filename             string       `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Base                 *BaseOptions `protobuf:"bytes,2,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*FileLoggerOptions) Descriptor 

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

func (FileLoggerOptions) Export 

func (opts FileLoggerOptions) Export() options.LoggerProducer

Export takes a protobuf RPC FileLoggerOptions struct and returns the analogous Jasper options.LoggerProducer.

func (*FileLoggerOptions) GetBase 

func (m *FileLoggerOptions) GetBase() *BaseOptions

func (*FileLoggerOptions) GetFilename 

func (m *FileLoggerOptions) GetFilename() string

func (*FileLoggerOptions) ProtoMessage 

func (*FileLoggerOptions) ProtoMessage()

func (*FileLoggerOptions) Reset 

func (m *FileLoggerOptions) Reset()

func (*FileLoggerOptions) String 

func (m *FileLoggerOptions) String() string

func (*FileLoggerOptions) XXX_DiscardUnknown 

func (m *FileLoggerOptions) XXX_DiscardUnknown()

func (*FileLoggerOptions) XXX_Marshal 

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

func (*FileLoggerOptions) XXX_Merge 

func (m *FileLoggerOptions) XXX_Merge(src proto.Message)

func (*FileLoggerOptions) XXX_Size 

func (m *FileLoggerOptions) XXX_Size() int

func (*FileLoggerOptions) XXX_Unmarshal 

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

type Filter 

type Filter struct {
	Name                 FilterSpecifications `protobuf:"varint,1,opt,name=name,proto3,enum=jasper.FilterSpecifications" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func ConvertFilter 

func ConvertFilter(f options.Filter) *Filter

ConvertFilter takes a Jasper Filter struct and returns an equivalent protobuf RPC *Filter struct.

func (*Filter) Descriptor 

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

func (*Filter) GetName 

func (m *Filter) GetName() FilterSpecifications

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

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

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

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

type FilterSpecifications 

type FilterSpecifications int32
const (
	FilterSpecifications_ALL        FilterSpecifications = 0
	FilterSpecifications_RUNNING    FilterSpecifications = 1
	FilterSpecifications_TERMINATED FilterSpecifications = 2
	FilterSpecifications_FAILED     FilterSpecifications = 3
	FilterSpecifications_SUCCESSFUL FilterSpecifications = 4
)

func (FilterSpecifications) EnumDescriptor 

func (FilterSpecifications) EnumDescriptor() ([]byte, []int)

func (FilterSpecifications) String 

func (x FilterSpecifications) String() string

type IDResponse 

type IDResponse struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IDResponse) Descriptor 

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

func (*IDResponse) GetValue 

func (m *IDResponse) GetValue() string

func (*IDResponse) ProtoMessage 

func (*IDResponse) ProtoMessage()

func (*IDResponse) Reset 

func (m *IDResponse) Reset()

func (*IDResponse) String 

func (m *IDResponse) String() string

func (*IDResponse) XXX_DiscardUnknown 

func (m *IDResponse) XXX_DiscardUnknown()

func (*IDResponse) XXX_Marshal 

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

func (*IDResponse) XXX_Merge 

func (m *IDResponse) XXX_Merge(src proto.Message)

func (*IDResponse) XXX_Size 

func (m *IDResponse) XXX_Size() int

func (*IDResponse) XXX_Unmarshal 

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

type InMemoryLoggerOptions 

type InMemoryLoggerOptions struct {
	InMemoryCap          int64        `protobuf:"varint,1,opt,name=in_memory_cap,json=inMemoryCap,proto3" json:"in_memory_cap,omitempty"`
	Base                 *BaseOptions `protobuf:"bytes,2,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*InMemoryLoggerOptions) Descriptor 

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

func (InMemoryLoggerOptions) Export 

func (opts InMemoryLoggerOptions) Export() options.LoggerProducer

Export takes a protobuf RPC InMemoryLoggerOptions struct and returns the analogous Jasper options.LoggerProducer.

func (*InMemoryLoggerOptions) GetBase 

func (m *InMemoryLoggerOptions) GetBase() *BaseOptions

func (*InMemoryLoggerOptions) GetInMemoryCap 

func (m *InMemoryLoggerOptions) GetInMemoryCap() int64

func (*InMemoryLoggerOptions) ProtoMessage 

func (*InMemoryLoggerOptions) ProtoMessage()

func (*InMemoryLoggerOptions) Reset 

func (m *InMemoryLoggerOptions) Reset()

func (*InMemoryLoggerOptions) String 

func (m *InMemoryLoggerOptions) String() string

func (*InMemoryLoggerOptions) XXX_DiscardUnknown 

func (m *InMemoryLoggerOptions) XXX_DiscardUnknown()

func (*InMemoryLoggerOptions) XXX_Marshal 

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

func (*InMemoryLoggerOptions) XXX_Merge 

func (m *InMemoryLoggerOptions) XXX_Merge(src proto.Message)

func (*InMemoryLoggerOptions) XXX_Size 

func (m *InMemoryLoggerOptions) XXX_Size() int

func (*InMemoryLoggerOptions) XXX_Unmarshal 

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

type InheritedLoggerOptions 

type InheritedLoggerOptions struct {
	Base                 *BaseOptions `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*InheritedLoggerOptions) Descriptor 

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

func (InheritedLoggerOptions) Export 

func (opts InheritedLoggerOptions) Export() options.LoggerProducer

Export takes a protobuf RPC InheritedLoggerOptions struct and returns the analogous Jasper options.LoggerProducer.

func (*InheritedLoggerOptions) GetBase 

func (m *InheritedLoggerOptions) GetBase() *BaseOptions

func (*InheritedLoggerOptions) ProtoMessage 

func (*InheritedLoggerOptions) ProtoMessage()

func (*InheritedLoggerOptions) Reset 

func (m *InheritedLoggerOptions) Reset()

func (*InheritedLoggerOptions) String 

func (m *InheritedLoggerOptions) String() string

func (*InheritedLoggerOptions) XXX_DiscardUnknown 

func (m *InheritedLoggerOptions) XXX_DiscardUnknown()

func (*InheritedLoggerOptions) XXX_Marshal 

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

func (*InheritedLoggerOptions) XXX_Merge 

func (m *InheritedLoggerOptions) XXX_Merge(src proto.Message)

func (*InheritedLoggerOptions) XXX_Size 

func (m *InheritedLoggerOptions) XXX_Size() int

func (*InheritedLoggerOptions) XXX_Unmarshal 

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

type JasperProcessID 

type JasperProcessID struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JasperProcessID) Descriptor 

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

func (*JasperProcessID) GetValue 

func (m *JasperProcessID) GetValue() string

func (*JasperProcessID) ProtoMessage 

func (*JasperProcessID) ProtoMessage()

func (*JasperProcessID) Reset 

func (m *JasperProcessID) Reset()

func (*JasperProcessID) String 

func (m *JasperProcessID) String() string

func (*JasperProcessID) XXX_DiscardUnknown 

func (m *JasperProcessID) XXX_DiscardUnknown()

func (*JasperProcessID) XXX_Marshal 

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

func (*JasperProcessID) XXX_Merge 

func (m *JasperProcessID) XXX_Merge(src proto.Message)

func (*JasperProcessID) XXX_Size 

func (m *JasperProcessID) XXX_Size() int

func (*JasperProcessID) XXX_Unmarshal 

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

type JasperProcessManagerClient 

type JasperProcessManagerClient interface {
	// Manager functions
	ID(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*IDResponse, error)
	Create(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*ProcessInfo, error)
	List(ctx context.Context, in *Filter, opts ...grpc.CallOption) (JasperProcessManager_ListClient, error)
	Group(ctx context.Context, in *TagName, opts ...grpc.CallOption) (JasperProcessManager_GroupClient, error)
	Get(ctx context.Context, in *JasperProcessID, opts ...grpc.CallOption) (*ProcessInfo, error)
	Signal(ctx context.Context, in *SignalProcess, opts ...grpc.CallOption) (*OperationOutcome, error)
	Clear(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*OperationOutcome, error)
	Close(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*OperationOutcome, error)
	// Process functions
	TagProcess(ctx context.Context, in *ProcessTags, opts ...grpc.CallOption) (*OperationOutcome, error)
	ResetTags(ctx context.Context, in *JasperProcessID, opts ...grpc.CallOption) (*OperationOutcome, error)
	GetTags(ctx context.Context, in *JasperProcessID, opts ...grpc.CallOption) (*ProcessTags, error)
	RegisterSignalTriggerID(ctx context.Context, in *SignalTriggerParams, opts ...grpc.CallOption) (*OperationOutcome, error)
	Wait(ctx context.Context, in *JasperProcessID, opts ...grpc.CallOption) (*OperationOutcome, error)
	Respawn(ctx context.Context, in *JasperProcessID, opts ...grpc.CallOption) (*ProcessInfo, error)
	// ScriptingHarness functions
	ScriptingHarnessCreate(ctx context.Context, in *ScriptingOptions, opts ...grpc.CallOption) (*ScriptingHarnessID, error)
	ScriptingHarnessCheck(ctx context.Context, in *ScriptingHarnessID, opts ...grpc.CallOption) (*OperationOutcome, error)
	ScriptingHarnessSetup(ctx context.Context, in *ScriptingHarnessID, opts ...grpc.CallOption) (*OperationOutcome, error)
	ScriptingHarnessCleanup(ctx context.Context, in *ScriptingHarnessID, opts ...grpc.CallOption) (*OperationOutcome, error)
	ScriptingHarnessRun(ctx context.Context, in *ScriptingHarnessRunArgs, opts ...grpc.CallOption) (*OperationOutcome, error)
	ScriptingHarnessBuild(ctx context.Context, in *ScriptingHarnessBuildArgs, opts ...grpc.CallOption) (*ScriptingHarnessBuildResponse, error)
	ScriptingHarnessRunScript(ctx context.Context, in *ScriptingHarnessRunScriptArgs, opts ...grpc.CallOption) (*OperationOutcome, error)
	ScriptingHarnessTest(ctx context.Context, in *ScriptingHarnessTestArgs, opts ...grpc.CallOption) (*ScriptingHarnessTestResponse, error)
	// Logging functions
	LoggingCacheCreate(ctx context.Context, in *LoggingCacheCreateArgs, opts ...grpc.CallOption) (*LoggingCacheInstance, error)
	LoggingCacheGet(ctx context.Context, in *LoggingCacheArgs, opts ...grpc.CallOption) (*LoggingCacheInstance, error)
	LoggingCacheRemove(ctx context.Context, in *LoggingCacheArgs, opts ...grpc.CallOption) (*OperationOutcome, error)
	LoggingCacheCloseAndRemove(ctx context.Context, in *LoggingCacheArgs, opts ...grpc.CallOption) (*OperationOutcome, error)
	LoggingCacheClear(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*OperationOutcome, error)
	LoggingCacheLen(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LoggingCacheSize, error)
	LoggingCachePrune(ctx context.Context, in *timestamp.Timestamp, opts ...grpc.CallOption) (*OperationOutcome, error)
	// Remote specific functions
	Status(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*StatusResponse, error)
	DownloadFile(ctx context.Context, in *DownloadInfo, opts ...grpc.CallOption) (*OperationOutcome, error)
	GetLogStream(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*LogStream, error)
	SignalEvent(ctx context.Context, in *EventName, opts ...grpc.CallOption) (*OperationOutcome, error)
	WriteFile(ctx context.Context, opts ...grpc.CallOption) (JasperProcessManager_WriteFileClient, error)
	SendMessages(ctx context.Context, in *LoggingPayload, opts ...grpc.CallOption) (*OperationOutcome, error)
}

JasperProcessManagerClient is the client API for JasperProcessManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJasperProcessManagerClient 

func NewJasperProcessManagerClient(cc *grpc.ClientConn) JasperProcessManagerClient

type JasperProcessManagerServer 

type JasperProcessManagerServer interface {
	// Manager functions
	ID(context.Context, *empty.Empty) (*IDResponse, error)
	Create(context.Context, *CreateOptions) (*ProcessInfo, error)
	List(*Filter, JasperProcessManager_ListServer) error
	Group(*TagName, JasperProcessManager_GroupServer) error
	Get(context.Context, *JasperProcessID) (*ProcessInfo, error)
	Signal(context.Context, *SignalProcess) (*OperationOutcome, error)
	Clear(context.Context, *empty.Empty) (*OperationOutcome, error)
	Close(context.Context, *empty.Empty) (*OperationOutcome, error)
	// Process functions
	TagProcess(context.Context, *ProcessTags) (*OperationOutcome, error)
	ResetTags(context.Context, *JasperProcessID) (*OperationOutcome, error)
	GetTags(context.Context, *JasperProcessID) (*ProcessTags, error)
	RegisterSignalTriggerID(context.Context, *SignalTriggerParams) (*OperationOutcome, error)
	Wait(context.Context, *JasperProcessID) (*OperationOutcome, error)
	Respawn(context.Context, *JasperProcessID) (*ProcessInfo, error)
	// ScriptingHarness functions
	ScriptingHarnessCreate(context.Context, *ScriptingOptions) (*ScriptingHarnessID, error)
	ScriptingHarnessCheck(context.Context, *ScriptingHarnessID) (*OperationOutcome, error)
	ScriptingHarnessSetup(context.Context, *ScriptingHarnessID) (*OperationOutcome, error)
	ScriptingHarnessCleanup(context.Context, *ScriptingHarnessID) (*OperationOutcome, error)
	ScriptingHarnessRun(context.Context, *ScriptingHarnessRunArgs) (*OperationOutcome, error)
	ScriptingHarnessBuild(context.Context, *ScriptingHarnessBuildArgs) (*ScriptingHarnessBuildResponse, error)
	ScriptingHarnessRunScript(context.Context, *ScriptingHarnessRunScriptArgs) (*OperationOutcome, error)
	ScriptingHarnessTest(context.Context, *ScriptingHarnessTestArgs) (*ScriptingHarnessTestResponse, error)
	// Logging functions
	LoggingCacheCreate(context.Context, *LoggingCacheCreateArgs) (*LoggingCacheInstance, error)
	LoggingCacheGet(context.Context, *LoggingCacheArgs) (*LoggingCacheInstance, error)
	LoggingCacheRemove(context.Context, *LoggingCacheArgs) (*OperationOutcome, error)
	LoggingCacheCloseAndRemove(context.Context, *LoggingCacheArgs) (*OperationOutcome, error)
	LoggingCacheClear(context.Context, *empty.Empty) (*OperationOutcome, error)
	LoggingCacheLen(context.Context, *empty.Empty) (*LoggingCacheSize, error)
	LoggingCachePrune(context.Context, *timestamp.Timestamp) (*OperationOutcome, error)
	// Remote specific functions
	Status(context.Context, *empty.Empty) (*StatusResponse, error)
	DownloadFile(context.Context, *DownloadInfo) (*OperationOutcome, error)
	GetLogStream(context.Context, *LogRequest) (*LogStream, error)
	SignalEvent(context.Context, *EventName) (*OperationOutcome, error)
	WriteFile(JasperProcessManager_WriteFileServer) error
	SendMessages(context.Context, *LoggingPayload) (*OperationOutcome, error)
}

JasperProcessManagerServer is the server API for JasperProcessManager service.

type JasperProcessManager_GroupClient 

type JasperProcessManager_GroupClient interface {
	Recv() (*ProcessInfo, error)
	grpc.ClientStream
}

type JasperProcessManager_GroupServer 

type JasperProcessManager_GroupServer interface {
	Send(*ProcessInfo) error
	grpc.ServerStream
}

type JasperProcessManager_ListClient 

type JasperProcessManager_ListClient interface {
	Recv() (*ProcessInfo, error)
	grpc.ClientStream
}

type JasperProcessManager_ListServer 

type JasperProcessManager_ListServer interface {
	Send(*ProcessInfo) error
	grpc.ServerStream
}

type JasperProcessManager_WriteFileClient 

type JasperProcessManager_WriteFileClient interface {
	Send(*WriteFileInfo) error
	CloseAndRecv() (*OperationOutcome, error)
	grpc.ClientStream
}

type JasperProcessManager_WriteFileServer 

type JasperProcessManager_WriteFileServer interface {
	SendAndClose(*OperationOutcome) error
	Recv() (*WriteFileInfo, error)
	grpc.ServerStream
}

type LogFormat 

type LogFormat int32
const (
	LogFormat_LOGFORMATUNKNOWN LogFormat = 0
	LogFormat_LOGFORMATDEFAULT LogFormat = 1
	LogFormat_LOGFORMATJSON    LogFormat = 2
	LogFormat_LOGFORMATPLAIN   LogFormat = 3
)

func ConvertLogFormat 

func ConvertLogFormat(f options.LogFormat) LogFormat

ConvertLogFormat takes a Jasper LogFormat struct and returns an equivalent protobuf RPC LogFormat struct. ConvertLogFormat is the inverse of (LogFormat) Export().

func (LogFormat) EnumDescriptor 

func (LogFormat) EnumDescriptor() ([]byte, []int)

func (LogFormat) Export 

func (f LogFormat) Export() options.LogFormat

Export takes a protobuf RPC LogFormat struct and returns the analogous Jasper LogFormat struct.

func (LogFormat) String 

func (x LogFormat) String() string

type LogLevel 

type LogLevel struct {
	Threshold            int32    `protobuf:"varint,1,opt,name=threshold,proto3" json:"threshold,omitempty"`
	Default              int32    `protobuf:"varint,2,opt,name=default,proto3" json:"default,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ConvertLogLevel 

func ConvertLogLevel(l level.Priority) *LogLevel

ConvertLogLevel takes a send LevelInfo struct and returns an equivalent protobuf RPC LogLevel struct. ConvertLogLevel is the inverse of (*LogLevel) Export().

func (*LogLevel) Descriptor 

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

func (*LogLevel) Export 

func (l *LogLevel) Export() level.Priority

Export takes a protobuf RPC LogLevel struct and returns the analogous send LevelInfo struct.

func (*LogLevel) GetDefault 

func (m *LogLevel) GetDefault() int32

func (*LogLevel) GetThreshold 

func (m *LogLevel) GetThreshold() int32

func (*LogLevel) ProtoMessage 

func (*LogLevel) ProtoMessage()

func (*LogLevel) Reset 

func (m *LogLevel) Reset()

func (*LogLevel) String 

func (m *LogLevel) String() string

func (*LogLevel) XXX_DiscardUnknown 

func (m *LogLevel) XXX_DiscardUnknown()

func (*LogLevel) XXX_Marshal 

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

func (*LogLevel) XXX_Merge 

func (m *LogLevel) XXX_Merge(src proto.Message)

func (*LogLevel) XXX_Size 

func (m *LogLevel) XXX_Size() int

func (*LogLevel) XXX_Unmarshal 

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

type LogRequest 

type LogRequest struct {
	Id                   *JasperProcessID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Count                int64            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LogRequest) Descriptor 

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

func (*LogRequest) GetCount 

func (m *LogRequest) GetCount() int64

func (*LogRequest) GetId 

func (m *LogRequest) GetId() *JasperProcessID

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

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

func (*LogRequest) XXX_Merge 

func (m *LogRequest) XXX_Merge(src proto.Message)

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

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

type LogStream 

type LogStream struct {
	Logs                 []string `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	Done                 bool     `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ConvertLogStream 

func ConvertLogStream(l jasper.LogStream) *LogStream

ConvertLogStream takes a Jasper LogStream and returns an equivalent protobuf RPC LogStream. ConvertLogStream is the inverse of (*LogStream) Export().

func (*LogStream) Descriptor 

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

func (*LogStream) Export 

func (l *LogStream) Export() jasper.LogStream

Export takes a protobuf RPC LogStream and returns the analogous Jasper LogStream.

func (*LogStream) GetDone 

func (m *LogStream) GetDone() bool

func (*LogStream) GetLogs 

func (m *LogStream) GetLogs() []string

func (*LogStream) ProtoMessage 

func (*LogStream) ProtoMessage()

func (*LogStream) Reset 

func (m *LogStream) Reset()

func (*LogStream) String 

func (m *LogStream) String() string

func (*LogStream) XXX_DiscardUnknown 

func (m *LogStream) XXX_DiscardUnknown()

func (*LogStream) XXX_Marshal 

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

func (*LogStream) XXX_Merge 

func (m *LogStream) XXX_Merge(src proto.Message)

func (*LogStream) XXX_Size 

func (m *LogStream) XXX_Size() int

func (*LogStream) XXX_Unmarshal 

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

type LoggerConfig 

type LoggerConfig struct {
	// Types that are valid to be assigned to Producer:
	//	*LoggerConfig_Default
	//	*LoggerConfig_File
	//	*LoggerConfig_Inherited
	//	*LoggerConfig_InMemory
	//	*LoggerConfig_Raw
	//	*LoggerConfig_Splunk
	Producer             isLoggerConfig_Producer `protobuf_oneof:"producer"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func ConvertLoggerConfig 

func ConvertLoggerConfig(config *options.LoggerConfig) (*LoggerConfig, error)

ConvertLoggerConfig takes a Jasper options.LoggerConfig struct and returns an equivalent protobuf RPC LoggerConfig struct. ConvertLoggerConfig is the inverse of (LoggerConfig) Export().

func (*LoggerConfig) Descriptor 

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

func (LoggerConfig) Export 

func (logger LoggerConfig) Export() (*options.LoggerConfig, error)

Export takes a protobuf RPC Logger struct and returns the analogous Jasper Logger struct.

func (*LoggerConfig) GetDefault 

func (m *LoggerConfig) GetDefault() *DefaultLoggerOptions

func (*LoggerConfig) GetFile 

func (m *LoggerConfig) GetFile() *FileLoggerOptions

func (*LoggerConfig) GetInMemory 

func (m *LoggerConfig) GetInMemory() *InMemoryLoggerOptions

func (*LoggerConfig) GetInherited 

func (m *LoggerConfig) GetInherited() *InheritedLoggerOptions

func (*LoggerConfig) GetProducer 

func (m *LoggerConfig) GetProducer() isLoggerConfig_Producer

func (*LoggerConfig) GetRaw 

func (m *LoggerConfig) GetRaw() *RawLoggerConfig

func (*LoggerConfig) GetSplunk 

func (m *LoggerConfig) GetSplunk() *SplunkLoggerOptions

func (*LoggerConfig) ProtoMessage 

func (*LoggerConfig) ProtoMessage()

func (*LoggerConfig) Reset 

func (m *LoggerConfig) Reset()

func (*LoggerConfig) String 

func (m *LoggerConfig) String() string

func (*LoggerConfig) XXX_DiscardUnknown 

func (m *LoggerConfig) XXX_DiscardUnknown()

func (*LoggerConfig) XXX_Marshal 

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

func (*LoggerConfig) XXX_Merge 

func (m *LoggerConfig) XXX_Merge(src proto.Message)

func (*LoggerConfig) XXX_OneofWrappers 

func (*LoggerConfig) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoggerConfig) XXX_Size 

func (m *LoggerConfig) XXX_Size() int

func (*LoggerConfig) XXX_Unmarshal 

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

type LoggerConfig_Default 

type LoggerConfig_Default struct {
	Default *DefaultLoggerOptions `protobuf:"bytes,1,opt,name=default,proto3,oneof"`
}

type LoggerConfig_File 

type LoggerConfig_File struct {
	File *FileLoggerOptions `protobuf:"bytes,2,opt,name=file,proto3,oneof"`
}

type LoggerConfig_InMemory 

type LoggerConfig_InMemory struct {
	InMemory *InMemoryLoggerOptions `protobuf:"bytes,4,opt,name=in_memory,json=inMemory,proto3,oneof"`
}

type LoggerConfig_Inherited 

type LoggerConfig_Inherited struct {
	Inherited *InheritedLoggerOptions `protobuf:"bytes,3,opt,name=inherited,proto3,oneof"`
}

type LoggerConfig_Raw 

type LoggerConfig_Raw struct {
	Raw *RawLoggerConfig `protobuf:"bytes,5,opt,name=raw,proto3,oneof"`
}

type LoggerConfig_Splunk 

type LoggerConfig_Splunk struct {
	Splunk *SplunkLoggerOptions `protobuf:"bytes,6,opt,name=splunk,proto3,oneof"`
}

type LoggingCacheArgs 

type LoggingCacheArgs struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoggingCacheArgs) Descriptor 

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

func (*LoggingCacheArgs) GetName 

func (m *LoggingCacheArgs) GetName() string

func (*LoggingCacheArgs) ProtoMessage 

func (*LoggingCacheArgs) ProtoMessage()

func (*LoggingCacheArgs) Reset 

func (m *LoggingCacheArgs) Reset()

func (*LoggingCacheArgs) String 

func (m *LoggingCacheArgs) String() string

func (*LoggingCacheArgs) XXX_DiscardUnknown 

func (m *LoggingCacheArgs) XXX_DiscardUnknown()

func (*LoggingCacheArgs) XXX_Marshal 

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

func (*LoggingCacheArgs) XXX_Merge 

func (m *LoggingCacheArgs) XXX_Merge(src proto.Message)

func (*LoggingCacheArgs) XXX_Size 

func (m *LoggingCacheArgs) XXX_Size() int

func (*LoggingCacheArgs) XXX_Unmarshal 

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

type LoggingCacheCreateArgs 

type LoggingCacheCreateArgs struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options              *OutputOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func ConvertLoggingCreateArgs 

func ConvertLoggingCreateArgs(id string, opts *options.Output) (*LoggingCacheCreateArgs, error)

ConvertLoggingCreateArgs takes the given ID and returns an equivalent protobuf RPC LoggingCacheCreateArgs.

func (*LoggingCacheCreateArgs) Descriptor 

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

func (*LoggingCacheCreateArgs) GetName 

func (m *LoggingCacheCreateArgs) GetName() string

func (*LoggingCacheCreateArgs) GetOptions 

func (m *LoggingCacheCreateArgs) GetOptions() *OutputOptions

func (*LoggingCacheCreateArgs) ProtoMessage 

func (*LoggingCacheCreateArgs) ProtoMessage()

func (*LoggingCacheCreateArgs) Reset 

func (m *LoggingCacheCreateArgs) Reset()

func (*LoggingCacheCreateArgs) String 

func (m *LoggingCacheCreateArgs) String() string

func (*LoggingCacheCreateArgs) XXX_DiscardUnknown 

func (m *LoggingCacheCreateArgs) XXX_DiscardUnknown()

func (*LoggingCacheCreateArgs) XXX_Marshal 

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

func (*LoggingCacheCreateArgs) XXX_Merge 

func (m *LoggingCacheCreateArgs) XXX_Merge(src proto.Message)

func (*LoggingCacheCreateArgs) XXX_Size 

func (m *LoggingCacheCreateArgs) XXX_Size() int

func (*LoggingCacheCreateArgs) XXX_Unmarshal 

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

type LoggingCacheInstance 

type LoggingCacheInstance struct {
	Outcome              *OperationOutcome    `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Id                   string               `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Manager              string               `protobuf:"bytes,3,opt,name=manager,proto3" json:"manager,omitempty"`
	Accessed             *timestamp.Timestamp `protobuf:"bytes,4,opt,name=accessed,proto3" json:"accessed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func ConvertCachedLogger 

func ConvertCachedLogger(opts *options.CachedLogger) *LoggingCacheInstance

ConvertCachedLogger takes CachedLogger options and returns an equivalent protobuf RPC LoggingCacheInstance. ConvertLoggingPayload is the inverse of (*LoggingCacheInstance) Export().

func (*LoggingCacheInstance) Descriptor 

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

func (*LoggingCacheInstance) Export 

func (l *LoggingCacheInstance) Export() (*options.CachedLogger, error)

Export takes a protobuf RPC LoggingCacheInstance and returns the analogous CacheLogger options.

func (*LoggingCacheInstance) GetAccessed 

func (m *LoggingCacheInstance) GetAccessed() *timestamp.Timestamp

func (*LoggingCacheInstance) GetId 

func (m *LoggingCacheInstance) GetId() string

func (*LoggingCacheInstance) GetManager 

func (m *LoggingCacheInstance) GetManager() string

func (*LoggingCacheInstance) GetOutcome 

func (m *LoggingCacheInstance) GetOutcome() *OperationOutcome

func (*LoggingCacheInstance) ProtoMessage 

func (*LoggingCacheInstance) ProtoMessage()

func (*LoggingCacheInstance) Reset 

func (m *LoggingCacheInstance) Reset()

func (*LoggingCacheInstance) String 

func (m *LoggingCacheInstance) String() string

func (*LoggingCacheInstance) XXX_DiscardUnknown 

func (m *LoggingCacheInstance) XXX_DiscardUnknown()

func (*LoggingCacheInstance) XXX_Marshal 

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

func (*LoggingCacheInstance) XXX_Merge 

func (m *LoggingCacheInstance) XXX_Merge(src proto.Message)

func (*LoggingCacheInstance) XXX_Size 

func (m *LoggingCacheInstance) XXX_Size() int

func (*LoggingCacheInstance) XXX_Unmarshal 

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

type LoggingCacheSize 

type LoggingCacheSize struct {
	Outcome              *OperationOutcome `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Id                   string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Size                 int64             `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*LoggingCacheSize) Descriptor 

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

func (*LoggingCacheSize) GetId 

func (m *LoggingCacheSize) GetId() string

func (*LoggingCacheSize) GetOutcome 

func (m *LoggingCacheSize) GetOutcome() *OperationOutcome

func (*LoggingCacheSize) GetSize 

func (m *LoggingCacheSize) GetSize() int64

func (*LoggingCacheSize) ProtoMessage 

func (*LoggingCacheSize) ProtoMessage()

func (*LoggingCacheSize) Reset 

func (m *LoggingCacheSize) Reset()

func (*LoggingCacheSize) String 

func (m *LoggingCacheSize) String() string

func (*LoggingCacheSize) XXX_DiscardUnknown 

func (m *LoggingCacheSize) XXX_DiscardUnknown()

func (*LoggingCacheSize) XXX_Marshal 

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

func (*LoggingCacheSize) XXX_Merge 

func (m *LoggingCacheSize) XXX_Merge(src proto.Message)

func (*LoggingCacheSize) XXX_Size 

func (m *LoggingCacheSize) XXX_Size() int

func (*LoggingCacheSize) XXX_Unmarshal 

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

type LoggingPayload 

type LoggingPayload struct {
	LoggerID             string                `protobuf:"bytes,1,opt,name=LoggerID,proto3" json:"LoggerID,omitempty"`
	Priority             int32                 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Format               LoggingPayloadFormat  `protobuf:"varint,3,opt,name=format,proto3,enum=jasper.LoggingPayloadFormat" json:"format,omitempty"`
	IsMulti              bool                  `protobuf:"varint,4,opt,name=is_multi,json=isMulti,proto3" json:"is_multi,omitempty"`
	PreferSendToError    bool                  `protobuf:"varint,5,opt,name=prefer_send_to_error,json=preferSendToError,proto3" json:"prefer_send_to_error,omitempty"`
	AddMetadata          bool                  `protobuf:"varint,6,opt,name=add_metadata,json=addMetadata,proto3" json:"add_metadata,omitempty"`
	Data                 []*LoggingPayloadData `protobuf:"bytes,7,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func ConvertLoggingPayload 

func ConvertLoggingPayload(in options.LoggingPayload) *LoggingPayload

ConvertLoggingPayload takes LoggingPayload options and returns an equivalent protobuf RPC LoggingPayload. ConvertLoggingPayload is the inverse of (*LoggingPayload) Export().

func (*LoggingPayload) Descriptor 

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

func (*LoggingPayload) Export 

func (lp *LoggingPayload) Export() *options.LoggingPayload

Export takes a protobuf RPC LoggingPayload and returns the analogous LoggingPayload options.

func (*LoggingPayload) GetAddMetadata 

func (m *LoggingPayload) GetAddMetadata() bool

func (*LoggingPayload) GetData 

func (m *LoggingPayload) GetData() []*LoggingPayloadData

func (*LoggingPayload) GetFormat 

func (m *LoggingPayload) GetFormat() LoggingPayloadFormat

func (*LoggingPayload) GetIsMulti 

func (m *LoggingPayload) GetIsMulti() bool

func (*LoggingPayload) GetLoggerID 

func (m *LoggingPayload) GetLoggerID() string

func (*LoggingPayload) GetPreferSendToError 

func (m *LoggingPayload) GetPreferSendToError() bool

func (*LoggingPayload) GetPriority 

func (m *LoggingPayload) GetPriority() int32

func (*LoggingPayload) ProtoMessage 

func (*LoggingPayload) ProtoMessage()

func (*LoggingPayload) Reset 

func (m *LoggingPayload) Reset()

func (*LoggingPayload) String 

func (m *LoggingPayload) String() string

func (*LoggingPayload) XXX_DiscardUnknown 

func (m *LoggingPayload) XXX_DiscardUnknown()

func (*LoggingPayload) XXX_Marshal 

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

func (*LoggingPayload) XXX_Merge 

func (m *LoggingPayload) XXX_Merge(src proto.Message)

func (*LoggingPayload) XXX_Size 

func (m *LoggingPayload) XXX_Size() int

func (*LoggingPayload) XXX_Unmarshal 

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

type LoggingPayloadData 

type LoggingPayloadData struct {
	// Types that are valid to be assigned to Data:
	//	*LoggingPayloadData_Msg
	//	*LoggingPayloadData_Raw
	Data                 isLoggingPayloadData_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*LoggingPayloadData) Descriptor 

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

func (*LoggingPayloadData) GetData 

func (m *LoggingPayloadData) GetData() isLoggingPayloadData_Data

func (*LoggingPayloadData) GetMsg 

func (m *LoggingPayloadData) GetMsg() string

func (*LoggingPayloadData) GetRaw 

func (m *LoggingPayloadData) GetRaw() []byte

func (*LoggingPayloadData) ProtoMessage 

func (*LoggingPayloadData) ProtoMessage()

func (*LoggingPayloadData) Reset 

func (m *LoggingPayloadData) Reset()

func (*LoggingPayloadData) String 

func (m *LoggingPayloadData) String() string

func (*LoggingPayloadData) XXX_DiscardUnknown 

func (m *LoggingPayloadData) XXX_DiscardUnknown()

func (*LoggingPayloadData) XXX_Marshal 

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

func (*LoggingPayloadData) XXX_Merge 

func (m *LoggingPayloadData) XXX_Merge(src proto.Message)

func (*LoggingPayloadData) XXX_OneofWrappers 

func (*LoggingPayloadData) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoggingPayloadData) XXX_Size 

func (m *LoggingPayloadData) XXX_Size() int

func (*LoggingPayloadData) XXX_Unmarshal 

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

type LoggingPayloadData_Msg 

type LoggingPayloadData_Msg struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3,oneof"`
}

type LoggingPayloadData_Raw 

type LoggingPayloadData_Raw struct {
	Raw []byte `protobuf:"bytes,2,opt,name=raw,proto3,oneof"`
}

type LoggingPayloadFormat 

type LoggingPayloadFormat int32
const (
	LoggingPayloadFormat_FORMATUNKNONW LoggingPayloadFormat = 0
	LoggingPayloadFormat_FORMATBSON    LoggingPayloadFormat = 1
	LoggingPayloadFormat_FORMATJSON    LoggingPayloadFormat = 2
	LoggingPayloadFormat_FORMATSTRING  LoggingPayloadFormat = 3
)

func ConvertLoggingPayloadFormat 

func ConvertLoggingPayloadFormat(in options.LoggingPayloadFormat) LoggingPayloadFormat

ConvertLoggingPayloadFormat takes LoggingPayloadFormat options and returns an equivalent protobuf RPC LoggingPayloadFormat. ConvertLoggingPayloadFormat is the inverse of (LoggingPayloadFormat) Export().

func (LoggingPayloadFormat) EnumDescriptor 

func (LoggingPayloadFormat) EnumDescriptor() ([]byte, []int)

func (LoggingPayloadFormat) Export 

func (lf LoggingPayloadFormat) Export() options.LoggingPayloadFormat

Export takes a protobuf RPC LoggingPayloadFormat and returns the analogous LoggingPayloadFormat.

func (LoggingPayloadFormat) String 

func (x LoggingPayloadFormat) String() string

type OperationOutcome 

type OperationOutcome struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Text                 string   `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	ExitCode             int32    `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OperationOutcome) Descriptor 

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

func (*OperationOutcome) GetExitCode 

func (m *OperationOutcome) GetExitCode() int32

func (*OperationOutcome) GetSuccess 

func (m *OperationOutcome) GetSuccess() bool

func (*OperationOutcome) GetText 

func (m *OperationOutcome) GetText() string

func (*OperationOutcome) ProtoMessage 

func (*OperationOutcome) ProtoMessage()

func (*OperationOutcome) Reset 

func (m *OperationOutcome) Reset()

func (*OperationOutcome) String 

func (m *OperationOutcome) String() string

func (*OperationOutcome) XXX_DiscardUnknown 

func (m *OperationOutcome) XXX_DiscardUnknown()

func (*OperationOutcome) XXX_Marshal 

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

func (*OperationOutcome) XXX_Merge 

func (m *OperationOutcome) XXX_Merge(src proto.Message)

func (*OperationOutcome) XXX_Size 

func (m *OperationOutcome) XXX_Size() int

func (*OperationOutcome) XXX_Unmarshal 

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

type OutputOptions 

type OutputOptions struct {
	Loggers               []*LoggerConfig `protobuf:"bytes,1,rep,name=loggers,proto3" json:"loggers,omitempty"`
	SuppressOutput        bool            `protobuf:"varint,2,opt,name=suppress_output,json=suppressOutput,proto3" json:"suppress_output,omitempty"`
	SuppressError         bool            `protobuf:"varint,3,opt,name=suppress_error,json=suppressError,proto3" json:"suppress_error,omitempty"`
	RedirectOutputToError bool            `` /* 129-byte string literal not displayed */
	RedirectErrorToOutput bool            `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}        `json:"-"`
	XXX_unrecognized      []byte          `json:"-"`
	XXX_sizecache         int32           `json:"-"`
}

func ConvertOutputOptions 

func ConvertOutputOptions(opts options.Output) (OutputOptions, error)

ConvertOutputOptions takes a Jasper OutputOptions struct and returns an equivalent protobuf RPC OutputOptions struct. ConvertOutputOptions is the inverse of (OutputOptions) Export().

func (*OutputOptions) Descriptor 

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

func (OutputOptions) Export 

func (opts OutputOptions) Export() (options.Output, error)

Export takes a protobuf RPC OutputOptions struct and returns the analogous Jasper OutputOptions struct.

func (*OutputOptions) GetLoggers 

func (m *OutputOptions) GetLoggers() []*LoggerConfig

func (*OutputOptions) GetRedirectErrorToOutput 

func (m *OutputOptions) GetRedirectErrorToOutput() bool

func (*OutputOptions) GetRedirectOutputToError 

func (m *OutputOptions) GetRedirectOutputToError() bool

func (*OutputOptions) GetSuppressError 

func (m *OutputOptions) GetSuppressError() bool

func (*OutputOptions) GetSuppressOutput 

func (m *OutputOptions) GetSuppressOutput() bool

func (*OutputOptions) ProtoMessage 

func (*OutputOptions) ProtoMessage()

func (*OutputOptions) Reset 

func (m *OutputOptions) Reset()

func (*OutputOptions) String 

func (m *OutputOptions) String() string

func (*OutputOptions) XXX_DiscardUnknown 

func (m *OutputOptions) XXX_DiscardUnknown()

func (*OutputOptions) XXX_Marshal 

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

func (*OutputOptions) XXX_Merge 

func (m *OutputOptions) XXX_Merge(src proto.Message)

func (*OutputOptions) XXX_Size 

func (m *OutputOptions) XXX_Size() int

func (*OutputOptions) XXX_Unmarshal 

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

type ProcessInfo 

type ProcessInfo struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Pid                  int64                `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	HostId               string               `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Running              bool                 `protobuf:"varint,4,opt,name=running,proto3" json:"running,omitempty"`
	Successful           bool                 `protobuf:"varint,5,opt,name=successful,proto3" json:"successful,omitempty"`
	Complete             bool                 `protobuf:"varint,6,opt,name=complete,proto3" json:"complete,omitempty"`
	Timedout             bool                 `protobuf:"varint,7,opt,name=timedout,proto3" json:"timedout,omitempty"`
	Options              *CreateOptions       `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	ExitCode             int32                `protobuf:"varint,9,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	StartAt              *timestamp.Timestamp `protobuf:"bytes,10,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	EndAt                *timestamp.Timestamp `protobuf:"bytes,11,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func ConvertProcessInfo 

func ConvertProcessInfo(info jasper.ProcessInfo) (*ProcessInfo, error)

ConvertProcessInfo takes a Jasper ProcessInfo struct and returns an equivalent protobuf RPC *ProcessInfo struct. ConvertProcessInfo is the inverse of (*ProcessInfo) Export().

func (*ProcessInfo) Descriptor 

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

func (*ProcessInfo) Export 

func (info *ProcessInfo) Export() (jasper.ProcessInfo, error)

Export takes a protobuf RPC ProcessInfo struct and returns the analogous Jasper ProcessInfo struct.

func (*ProcessInfo) GetComplete 

func (m *ProcessInfo) GetComplete() bool

func (*ProcessInfo) GetEndAt 

func (m *ProcessInfo) GetEndAt() *timestamp.Timestamp

func (*ProcessInfo) GetExitCode 

func (m *ProcessInfo) GetExitCode() int32

func (*ProcessInfo) GetHostId 

func (m *ProcessInfo) GetHostId() string

func (*ProcessInfo) GetId 

func (m *ProcessInfo) GetId() string

func (*ProcessInfo) GetOptions 

func (m *ProcessInfo) GetOptions() *CreateOptions

func (*ProcessInfo) GetPid 

func (m *ProcessInfo) GetPid() int64

func (*ProcessInfo) GetRunning 

func (m *ProcessInfo) GetRunning() bool

func (*ProcessInfo) GetStartAt 

func (m *ProcessInfo) GetStartAt() *timestamp.Timestamp

func (*ProcessInfo) GetSuccessful 

func (m *ProcessInfo) GetSuccessful() bool

func (*ProcessInfo) GetTimedout 

func (m *ProcessInfo) GetTimedout() bool

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) Reset 

func (m *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (m *ProcessInfo) String() string

func (*ProcessInfo) XXX_DiscardUnknown 

func (m *ProcessInfo) XXX_DiscardUnknown()

func (*ProcessInfo) XXX_Marshal 

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

func (*ProcessInfo) XXX_Merge 

func (m *ProcessInfo) XXX_Merge(src proto.Message)

func (*ProcessInfo) XXX_Size 

func (m *ProcessInfo) XXX_Size() int

func (*ProcessInfo) XXX_Unmarshal 

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

type ProcessTags 

type ProcessTags struct {
	ProcessID            string   `protobuf:"bytes,1,opt,name=processID,proto3" json:"processID,omitempty"`
	Tags                 []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessTags) Descriptor 

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

func (*ProcessTags) GetProcessID 

func (m *ProcessTags) GetProcessID() string

func (*ProcessTags) GetTags 

func (m *ProcessTags) GetTags() []string

func (*ProcessTags) ProtoMessage 

func (*ProcessTags) ProtoMessage()

func (*ProcessTags) Reset 

func (m *ProcessTags) Reset()

func (*ProcessTags) String 

func (m *ProcessTags) String() string

func (*ProcessTags) XXX_DiscardUnknown 

func (m *ProcessTags) XXX_DiscardUnknown()

func (*ProcessTags) XXX_Marshal 

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

func (*ProcessTags) XXX_Merge 

func (m *ProcessTags) XXX_Merge(src proto.Message)

func (*ProcessTags) XXX_Size 

func (m *ProcessTags) XXX_Size() int

func (*ProcessTags) XXX_Unmarshal 

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

type RawLoggerConfig 

type RawLoggerConfig struct {
	Format               RawLoggerConfigFormat `protobuf:"varint,1,opt,name=format,proto3,enum=jasper.RawLoggerConfigFormat" json:"format,omitempty"`
	ConfigData           []byte                `protobuf:"bytes,2,opt,name=config_data,json=configData,proto3" json:"config_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RawLoggerConfig) Descriptor 

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

func (RawLoggerConfig) Export 

func (logger RawLoggerConfig) Export() (*options.LoggerConfig, error)

Export takes a protobuf RPC RawLoggerConfig struct and returns the analogous Jasper options.LoggerConfig

func (*RawLoggerConfig) GetConfigData 

func (m *RawLoggerConfig) GetConfigData() []byte

func (*RawLoggerConfig) GetFormat 

func (m *RawLoggerConfig) GetFormat() RawLoggerConfigFormat

func (*RawLoggerConfig) ProtoMessage 

func (*RawLoggerConfig) ProtoMessage()

func (*RawLoggerConfig) Reset 

func (m *RawLoggerConfig) Reset()

func (*RawLoggerConfig) String 

func (m *RawLoggerConfig) String() string

func (*RawLoggerConfig) XXX_DiscardUnknown 

func (m *RawLoggerConfig) XXX_DiscardUnknown()

func (*RawLoggerConfig) XXX_Marshal 

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

func (*RawLoggerConfig) XXX_Merge 

func (m *RawLoggerConfig) XXX_Merge(src proto.Message)

func (*RawLoggerConfig) XXX_Size 

func (m *RawLoggerConfig) XXX_Size() int

func (*RawLoggerConfig) XXX_Unmarshal 

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

type RawLoggerConfigFormat 

type RawLoggerConfigFormat int32
const (
	RawLoggerConfigFormat_RAWLOGGERCONFIGFORMATJSON    RawLoggerConfigFormat = 0
	RawLoggerConfigFormat_RAWLOGGERCONFIGFORMATBSON    RawLoggerConfigFormat = 1
	RawLoggerConfigFormat_RAWLOGGERCONFIGFORMATUNKNOWN RawLoggerConfigFormat = 2
)

func ConvertRawLoggerConfigFormat 

func ConvertRawLoggerConfigFormat(f options.RawLoggerConfigFormat) RawLoggerConfigFormat

ConvertRawLoggerConfigFormat takes a Jasper RawLoggerConfigFormat type and returns an equivalent protobuf RPC RawLoggerConfigFormat enum. ConvertLogFormat is the inverse of (RawLoggerConfigFormat) Export().

func (RawLoggerConfigFormat) EnumDescriptor 

func (RawLoggerConfigFormat) EnumDescriptor() ([]byte, []int)

func (RawLoggerConfigFormat) Export 

func (f RawLoggerConfigFormat) Export() options.RawLoggerConfigFormat

Export takes a protobuf RPC RawLoggerConfigFormat enum and returns the analogous Jasper options.RawLoggerConfigFormat type.

func (RawLoggerConfigFormat) String 

func (x RawLoggerConfigFormat) String() string

type ScriptingHarnessBuildArgs 

type ScriptingHarnessBuildArgs struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Directory            string   `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"`
	Args                 []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingHarnessBuildArgs) Descriptor 

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

func (*ScriptingHarnessBuildArgs) GetArgs 

func (m *ScriptingHarnessBuildArgs) GetArgs() []string

func (*ScriptingHarnessBuildArgs) GetDirectory 

func (m *ScriptingHarnessBuildArgs) GetDirectory() string

func (*ScriptingHarnessBuildArgs) GetId 

func (m *ScriptingHarnessBuildArgs) GetId() string

func (*ScriptingHarnessBuildArgs) ProtoMessage 

func (*ScriptingHarnessBuildArgs) ProtoMessage()

func (*ScriptingHarnessBuildArgs) Reset 

func (m *ScriptingHarnessBuildArgs) Reset()

func (*ScriptingHarnessBuildArgs) String 

func (m *ScriptingHarnessBuildArgs) String() string

func (*ScriptingHarnessBuildArgs) XXX_DiscardUnknown 

func (m *ScriptingHarnessBuildArgs) XXX_DiscardUnknown()

func (*ScriptingHarnessBuildArgs) XXX_Marshal 

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

func (*ScriptingHarnessBuildArgs) XXX_Merge 

func (m *ScriptingHarnessBuildArgs) XXX_Merge(src proto.Message)

func (*ScriptingHarnessBuildArgs) XXX_Size 

func (m *ScriptingHarnessBuildArgs) XXX_Size() int

func (*ScriptingHarnessBuildArgs) XXX_Unmarshal 

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

type ScriptingHarnessBuildResponse 

type ScriptingHarnessBuildResponse struct {
	Outcome              *OperationOutcome `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Path                 string            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ScriptingHarnessBuildResponse) Descriptor 

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

func (*ScriptingHarnessBuildResponse) GetOutcome 

func (m *ScriptingHarnessBuildResponse) GetOutcome() *OperationOutcome

func (*ScriptingHarnessBuildResponse) GetPath 

func (m *ScriptingHarnessBuildResponse) GetPath() string

func (*ScriptingHarnessBuildResponse) ProtoMessage 

func (*ScriptingHarnessBuildResponse) ProtoMessage()

func (*ScriptingHarnessBuildResponse) Reset 

func (m *ScriptingHarnessBuildResponse) Reset()

func (*ScriptingHarnessBuildResponse) String 

func (m *ScriptingHarnessBuildResponse) String() string

func (*ScriptingHarnessBuildResponse) XXX_DiscardUnknown 

func (m *ScriptingHarnessBuildResponse) XXX_DiscardUnknown()

func (*ScriptingHarnessBuildResponse) XXX_Marshal 

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

func (*ScriptingHarnessBuildResponse) XXX_Merge 

func (m *ScriptingHarnessBuildResponse) XXX_Merge(src proto.Message)

func (*ScriptingHarnessBuildResponse) XXX_Size 

func (m *ScriptingHarnessBuildResponse) XXX_Size() int

func (*ScriptingHarnessBuildResponse) XXX_Unmarshal 

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

type ScriptingHarnessID 

type ScriptingHarnessID struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Setup                bool     `protobuf:"varint,2,opt,name=setup,proto3" json:"setup,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingHarnessID) Descriptor 

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

func (*ScriptingHarnessID) GetId 

func (m *ScriptingHarnessID) GetId() string

func (*ScriptingHarnessID) GetSetup 

func (m *ScriptingHarnessID) GetSetup() bool

func (*ScriptingHarnessID) ProtoMessage 

func (*ScriptingHarnessID) ProtoMessage()

func (*ScriptingHarnessID) Reset 

func (m *ScriptingHarnessID) Reset()

func (*ScriptingHarnessID) String 

func (m *ScriptingHarnessID) String() string

func (*ScriptingHarnessID) XXX_DiscardUnknown 

func (m *ScriptingHarnessID) XXX_DiscardUnknown()

func (*ScriptingHarnessID) XXX_Marshal 

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

func (*ScriptingHarnessID) XXX_Merge 

func (m *ScriptingHarnessID) XXX_Merge(src proto.Message)

func (*ScriptingHarnessID) XXX_Size 

func (m *ScriptingHarnessID) XXX_Size() int

func (*ScriptingHarnessID) XXX_Unmarshal 

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

type ScriptingHarnessRunArgs 

type ScriptingHarnessRunArgs struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Args                 []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingHarnessRunArgs) Descriptor 

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

func (*ScriptingHarnessRunArgs) GetArgs 

func (m *ScriptingHarnessRunArgs) GetArgs() []string

func (*ScriptingHarnessRunArgs) GetId 

func (m *ScriptingHarnessRunArgs) GetId() string

func (*ScriptingHarnessRunArgs) ProtoMessage 

func (*ScriptingHarnessRunArgs) ProtoMessage()

func (*ScriptingHarnessRunArgs) Reset 

func (m *ScriptingHarnessRunArgs) Reset()

func (*ScriptingHarnessRunArgs) String 

func (m *ScriptingHarnessRunArgs) String() string

func (*ScriptingHarnessRunArgs) XXX_DiscardUnknown 

func (m *ScriptingHarnessRunArgs) XXX_DiscardUnknown()

func (*ScriptingHarnessRunArgs) XXX_Marshal 

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

func (*ScriptingHarnessRunArgs) XXX_Merge 

func (m *ScriptingHarnessRunArgs) XXX_Merge(src proto.Message)

func (*ScriptingHarnessRunArgs) XXX_Size 

func (m *ScriptingHarnessRunArgs) XXX_Size() int

func (*ScriptingHarnessRunArgs) XXX_Unmarshal 

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

type ScriptingHarnessRunScriptArgs 

type ScriptingHarnessRunScriptArgs struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Script               string   `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingHarnessRunScriptArgs) Descriptor 

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

func (*ScriptingHarnessRunScriptArgs) GetId 

func (m *ScriptingHarnessRunScriptArgs) GetId() string

func (*ScriptingHarnessRunScriptArgs) GetScript 

func (m *ScriptingHarnessRunScriptArgs) GetScript() string

func (*ScriptingHarnessRunScriptArgs) ProtoMessage 

func (*ScriptingHarnessRunScriptArgs) ProtoMessage()

func (*ScriptingHarnessRunScriptArgs) Reset 

func (m *ScriptingHarnessRunScriptArgs) Reset()

func (*ScriptingHarnessRunScriptArgs) String 

func (m *ScriptingHarnessRunScriptArgs) String() string

func (*ScriptingHarnessRunScriptArgs) XXX_DiscardUnknown 

func (m *ScriptingHarnessRunScriptArgs) XXX_DiscardUnknown()

func (*ScriptingHarnessRunScriptArgs) XXX_Marshal 

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

func (*ScriptingHarnessRunScriptArgs) XXX_Merge 

func (m *ScriptingHarnessRunScriptArgs) XXX_Merge(src proto.Message)

func (*ScriptingHarnessRunScriptArgs) XXX_Size 

func (m *ScriptingHarnessRunScriptArgs) XXX_Size() int

func (*ScriptingHarnessRunScriptArgs) XXX_Unmarshal 

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

type ScriptingHarnessTestArgs 

type ScriptingHarnessTestArgs struct {
	Id                   string                         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Directory            string                         `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"`
	Options              []*ScriptingHarnessTestOptions `protobuf:"bytes,3,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ScriptingHarnessTestArgs) Descriptor 

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

func (*ScriptingHarnessTestArgs) Export 

func (a *ScriptingHarnessTestArgs) Export() ([]scripting.TestOptions, error)

Export takes a protobuf RPC ScriptingHarnessTestArgs and returns the analogous scripting TestOptions.

func (*ScriptingHarnessTestArgs) GetDirectory 

func (m *ScriptingHarnessTestArgs) GetDirectory() string

func (*ScriptingHarnessTestArgs) GetId 

func (m *ScriptingHarnessTestArgs) GetId() string

func (*ScriptingHarnessTestArgs) GetOptions 

func (m *ScriptingHarnessTestArgs) GetOptions() []*ScriptingHarnessTestOptions

func (*ScriptingHarnessTestArgs) ProtoMessage 

func (*ScriptingHarnessTestArgs) ProtoMessage()

func (*ScriptingHarnessTestArgs) Reset 

func (m *ScriptingHarnessTestArgs) Reset()

func (*ScriptingHarnessTestArgs) String 

func (m *ScriptingHarnessTestArgs) String() string

func (*ScriptingHarnessTestArgs) XXX_DiscardUnknown 

func (m *ScriptingHarnessTestArgs) XXX_DiscardUnknown()

func (*ScriptingHarnessTestArgs) XXX_Marshal 

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

func (*ScriptingHarnessTestArgs) XXX_Merge 

func (m *ScriptingHarnessTestArgs) XXX_Merge(src proto.Message)

func (*ScriptingHarnessTestArgs) XXX_Size 

func (m *ScriptingHarnessTestArgs) XXX_Size() int

func (*ScriptingHarnessTestArgs) XXX_Unmarshal 

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

type ScriptingHarnessTestOptions 

type ScriptingHarnessTestOptions struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args                 []string           `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Pattern              string             `protobuf:"bytes,3,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Timeout              *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Count                int32              `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func ConvertScriptingTestOptions 

func ConvertScriptingTestOptions(args []scripting.TestOptions) []*ScriptingHarnessTestOptions

ConvertScriptingTestResults takes scripting TestOptions and returns an equivalent protobuf RPC ScriptingHarnessTestOptions.

func (*ScriptingHarnessTestOptions) Descriptor 

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

func (*ScriptingHarnessTestOptions) GetArgs 

func (m *ScriptingHarnessTestOptions) GetArgs() []string

func (*ScriptingHarnessTestOptions) GetCount 

func (m *ScriptingHarnessTestOptions) GetCount() int32

func (*ScriptingHarnessTestOptions) GetName 

func (m *ScriptingHarnessTestOptions) GetName() string

func (*ScriptingHarnessTestOptions) GetPattern 

func (m *ScriptingHarnessTestOptions) GetPattern() string

func (*ScriptingHarnessTestOptions) GetTimeout 

func (m *ScriptingHarnessTestOptions) GetTimeout() *duration.Duration

func (*ScriptingHarnessTestOptions) ProtoMessage 

func (*ScriptingHarnessTestOptions) ProtoMessage()

func (*ScriptingHarnessTestOptions) Reset 

func (m *ScriptingHarnessTestOptions) Reset()

func (*ScriptingHarnessTestOptions) String 

func (m *ScriptingHarnessTestOptions) String() string

func (*ScriptingHarnessTestOptions) XXX_DiscardUnknown 

func (m *ScriptingHarnessTestOptions) XXX_DiscardUnknown()

func (*ScriptingHarnessTestOptions) XXX_Marshal 

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

func (*ScriptingHarnessTestOptions) XXX_Merge 

func (m *ScriptingHarnessTestOptions) XXX_Merge(src proto.Message)

func (*ScriptingHarnessTestOptions) XXX_Size 

func (m *ScriptingHarnessTestOptions) XXX_Size() int

func (*ScriptingHarnessTestOptions) XXX_Unmarshal 

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

type ScriptingHarnessTestResponse 

type ScriptingHarnessTestResponse struct {
	Outcome              *OperationOutcome             `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Results              []*ScriptingHarnessTestResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ScriptingHarnessTestResponse) Descriptor 

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

func (*ScriptingHarnessTestResponse) Export 

func (r *ScriptingHarnessTestResponse) Export() ([]scripting.TestResult, error)

Export takes a protobuf RPC ScriptingHarnessTestResponse and returns the analogous scripting TestResult.

func (*ScriptingHarnessTestResponse) GetOutcome 

func (m *ScriptingHarnessTestResponse) GetOutcome() *OperationOutcome

func (*ScriptingHarnessTestResponse) GetResults 

func (m *ScriptingHarnessTestResponse) GetResults() []*ScriptingHarnessTestResult

func (*ScriptingHarnessTestResponse) ProtoMessage 

func (*ScriptingHarnessTestResponse) ProtoMessage()

func (*ScriptingHarnessTestResponse) Reset 

func (m *ScriptingHarnessTestResponse) Reset()

func (*ScriptingHarnessTestResponse) String 

func (m *ScriptingHarnessTestResponse) String() string

func (*ScriptingHarnessTestResponse) XXX_DiscardUnknown 

func (m *ScriptingHarnessTestResponse) XXX_DiscardUnknown()

func (*ScriptingHarnessTestResponse) XXX_Marshal 

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

func (*ScriptingHarnessTestResponse) XXX_Merge 

func (m *ScriptingHarnessTestResponse) XXX_Merge(src proto.Message)

func (*ScriptingHarnessTestResponse) XXX_Size 

func (m *ScriptingHarnessTestResponse) XXX_Size() int

func (*ScriptingHarnessTestResponse) XXX_Unmarshal 

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

type ScriptingHarnessTestResult 

type ScriptingHarnessTestResult struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	StartAt              *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	Duration             *duration.Duration   `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	Outcome              string               `protobuf:"bytes,4,opt,name=outcome,proto3" json:"outcome,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func ConvertScriptingTestResults 

func ConvertScriptingTestResults(res []scripting.TestResult) []*ScriptingHarnessTestResult

ConvertScriptingTestResults takes scripting TestResults and returns an equivalent protobuf RPC ScriptingHarnessTestResult.

func (*ScriptingHarnessTestResult) Descriptor 

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

func (*ScriptingHarnessTestResult) GetDuration 

func (m *ScriptingHarnessTestResult) GetDuration() *duration.Duration

func (*ScriptingHarnessTestResult) GetName 

func (m *ScriptingHarnessTestResult) GetName() string

func (*ScriptingHarnessTestResult) GetOutcome 

func (m *ScriptingHarnessTestResult) GetOutcome() string

func (*ScriptingHarnessTestResult) GetStartAt 

func (m *ScriptingHarnessTestResult) GetStartAt() *timestamp.Timestamp

func (*ScriptingHarnessTestResult) ProtoMessage 

func (*ScriptingHarnessTestResult) ProtoMessage()

func (*ScriptingHarnessTestResult) Reset 

func (m *ScriptingHarnessTestResult) Reset()

func (*ScriptingHarnessTestResult) String 

func (m *ScriptingHarnessTestResult) String() string

func (*ScriptingHarnessTestResult) XXX_DiscardUnknown 

func (m *ScriptingHarnessTestResult) XXX_DiscardUnknown()

func (*ScriptingHarnessTestResult) XXX_Marshal 

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

func (*ScriptingHarnessTestResult) XXX_Merge 

func (m *ScriptingHarnessTestResult) XXX_Merge(src proto.Message)

func (*ScriptingHarnessTestResult) XXX_Size 

func (m *ScriptingHarnessTestResult) XXX_Size() int

func (*ScriptingHarnessTestResult) XXX_Unmarshal 

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

type ScriptingOptions 

type ScriptingOptions struct {
	// Types that are valid to be assigned to Value:
	//	*ScriptingOptions_Golang
	//	*ScriptingOptions_Python
	//	*ScriptingOptions_Roswell
	Value                isScriptingOptions_Value `protobuf_oneof:"value"`
	Environment          map[string]string        `` /* 163-byte string literal not displayed */
	Output               *OutputOptions           `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	Duration             int64                    `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func ConvertScriptingOptions 

func ConvertScriptingOptions(opts options.ScriptingHarness) (*ScriptingOptions, error)

ConvertScriptingOptions takes ScriptingHarness options and returns an equivalent protobuf RPC ScriptingOptions. ConvertScriptingOptions is the inverse of (*ScriptingOptions) Export().

func (*ScriptingOptions) Descriptor 

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

func (*ScriptingOptions) Export 

func (o *ScriptingOptions) Export() (options.ScriptingHarness, error)

Export takes a protobuf RPC ScriptingOptions and returns the analogous ScriptingHarness options.

func (*ScriptingOptions) GetDuration 

func (m *ScriptingOptions) GetDuration() int64

func (*ScriptingOptions) GetEnvironment 

func (m *ScriptingOptions) GetEnvironment() map[string]string

func (*ScriptingOptions) GetGolang 

func (m *ScriptingOptions) GetGolang() *ScriptingOptionsGolang

func (*ScriptingOptions) GetOutput 

func (m *ScriptingOptions) GetOutput() *OutputOptions

func (*ScriptingOptions) GetPython 

func (m *ScriptingOptions) GetPython() *ScriptingOptionsPython

func (*ScriptingOptions) GetRoswell 

func (m *ScriptingOptions) GetRoswell() *ScriptingOptionsRoswell

func (*ScriptingOptions) GetValue 

func (m *ScriptingOptions) GetValue() isScriptingOptions_Value

func (*ScriptingOptions) ProtoMessage 

func (*ScriptingOptions) ProtoMessage()

func (*ScriptingOptions) Reset 

func (m *ScriptingOptions) Reset()

func (*ScriptingOptions) String 

func (m *ScriptingOptions) String() string

func (*ScriptingOptions) XXX_DiscardUnknown 

func (m *ScriptingOptions) XXX_DiscardUnknown()

func (*ScriptingOptions) XXX_Marshal 

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

func (*ScriptingOptions) XXX_Merge 

func (m *ScriptingOptions) XXX_Merge(src proto.Message)

func (*ScriptingOptions) XXX_OneofWrappers 

func (*ScriptingOptions) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScriptingOptions) XXX_Size 

func (m *ScriptingOptions) XXX_Size() int

func (*ScriptingOptions) XXX_Unmarshal 

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

type ScriptingOptionsGolang 

type ScriptingOptionsGolang struct {
	Gopath               string   `protobuf:"bytes,1,opt,name=gopath,proto3" json:"gopath,omitempty"`
	Goroot               string   `protobuf:"bytes,2,opt,name=goroot,proto3" json:"goroot,omitempty"`
	Packages             []string `protobuf:"bytes,3,rep,name=packages,proto3" json:"packages,omitempty"`
	Directory            string   `protobuf:"bytes,4,opt,name=directory,proto3" json:"directory,omitempty"`
	UpdatePackages       bool     `protobuf:"varint,5,opt,name=update_packages,json=updatePackages,proto3" json:"update_packages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingOptionsGolang) Descriptor 

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

func (*ScriptingOptionsGolang) GetDirectory 

func (m *ScriptingOptionsGolang) GetDirectory() string

func (*ScriptingOptionsGolang) GetGopath 

func (m *ScriptingOptionsGolang) GetGopath() string

func (*ScriptingOptionsGolang) GetGoroot 

func (m *ScriptingOptionsGolang) GetGoroot() string

func (*ScriptingOptionsGolang) GetPackages 

func (m *ScriptingOptionsGolang) GetPackages() []string

func (*ScriptingOptionsGolang) GetUpdatePackages 

func (m *ScriptingOptionsGolang) GetUpdatePackages() bool

func (*ScriptingOptionsGolang) ProtoMessage 

func (*ScriptingOptionsGolang) ProtoMessage()

func (*ScriptingOptionsGolang) Reset 

func (m *ScriptingOptionsGolang) Reset()

func (*ScriptingOptionsGolang) String 

func (m *ScriptingOptionsGolang) String() string

func (*ScriptingOptionsGolang) XXX_DiscardUnknown 

func (m *ScriptingOptionsGolang) XXX_DiscardUnknown()

func (*ScriptingOptionsGolang) XXX_Marshal 

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

func (*ScriptingOptionsGolang) XXX_Merge 

func (m *ScriptingOptionsGolang) XXX_Merge(src proto.Message)

func (*ScriptingOptionsGolang) XXX_Size 

func (m *ScriptingOptionsGolang) XXX_Size() int

func (*ScriptingOptionsGolang) XXX_Unmarshal 

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

type ScriptingOptionsPython 

type ScriptingOptionsPython struct {
	VirtualEnvPath       string   `protobuf:"bytes,1,opt,name=virtual_env_path,json=virtualEnvPath,proto3" json:"virtual_env_path,omitempty"`
	RequirementsPath     string   `protobuf:"bytes,2,opt,name=assert.ents_path,json=requirementsPath,proto3" json:"requirements_path,omitempty"`
	InterpreterBinary    string   `protobuf:"bytes,3,opt,name=interpreter_binary,json=interpreterBinary,proto3" json:"interpreter_binary,omitempty"`
	Packages             []string `protobuf:"bytes,4,rep,name=packages,proto3" json:"packages,omitempty"`
	LegacyPython         bool     `protobuf:"varint,5,opt,name=legacy_python,json=legacyPython,proto3" json:"legacy_python,omitempty"`
	AddTestReqs          bool     `protobuf:"varint,6,opt,name=add_test_reqs,json=addTestReqs,proto3" json:"add_test_reqs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingOptionsPython) Descriptor 

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

func (*ScriptingOptionsPython) GetAddTestReqs 

func (m *ScriptingOptionsPython) GetAddTestReqs() bool

func (*ScriptingOptionsPython) GetInterpreterBinary 

func (m *ScriptingOptionsPython) GetInterpreterBinary() string

func (*ScriptingOptionsPython) GetLegacyPython 

func (m *ScriptingOptionsPython) GetLegacyPython() bool

func (*ScriptingOptionsPython) GetPackages 

func (m *ScriptingOptionsPython) GetPackages() []string

func (*ScriptingOptionsPython) GetRequirementsPath 

func (m *ScriptingOptionsPython) GetRequirementsPath() string

func (*ScriptingOptionsPython) GetVirtualEnvPath 

func (m *ScriptingOptionsPython) GetVirtualEnvPath() string

func (*ScriptingOptionsPython) ProtoMessage 

func (*ScriptingOptionsPython) ProtoMessage()

func (*ScriptingOptionsPython) Reset 

func (m *ScriptingOptionsPython) Reset()

func (*ScriptingOptionsPython) String 

func (m *ScriptingOptionsPython) String() string

func (*ScriptingOptionsPython) XXX_DiscardUnknown 

func (m *ScriptingOptionsPython) XXX_DiscardUnknown()

func (*ScriptingOptionsPython) XXX_Marshal 

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

func (*ScriptingOptionsPython) XXX_Merge 

func (m *ScriptingOptionsPython) XXX_Merge(src proto.Message)

func (*ScriptingOptionsPython) XXX_Size 

func (m *ScriptingOptionsPython) XXX_Size() int

func (*ScriptingOptionsPython) XXX_Unmarshal 

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

type ScriptingOptionsRoswell 

type ScriptingOptionsRoswell struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Systems              []string `protobuf:"bytes,2,rep,name=systems,proto3" json:"systems,omitempty"`
	Lisp                 string   `protobuf:"bytes,3,opt,name=lisp,proto3" json:"lisp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScriptingOptionsRoswell) Descriptor 

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

func (*ScriptingOptionsRoswell) GetLisp 

func (m *ScriptingOptionsRoswell) GetLisp() string

func (*ScriptingOptionsRoswell) GetPath 

func (m *ScriptingOptionsRoswell) GetPath() string

func (*ScriptingOptionsRoswell) GetSystems 

func (m *ScriptingOptionsRoswell) GetSystems() []string

func (*ScriptingOptionsRoswell) ProtoMessage 

func (*ScriptingOptionsRoswell) ProtoMessage()

func (*ScriptingOptionsRoswell) Reset 

func (m *ScriptingOptionsRoswell) Reset()

func (*ScriptingOptionsRoswell) String 

func (m *ScriptingOptionsRoswell) String() string

func (*ScriptingOptionsRoswell) XXX_DiscardUnknown 

func (m *ScriptingOptionsRoswell) XXX_DiscardUnknown()

func (*ScriptingOptionsRoswell) XXX_Marshal 

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

func (*ScriptingOptionsRoswell) XXX_Merge 

func (m *ScriptingOptionsRoswell) XXX_Merge(src proto.Message)

func (*ScriptingOptionsRoswell) XXX_Size 

func (m *ScriptingOptionsRoswell) XXX_Size() int

func (*ScriptingOptionsRoswell) XXX_Unmarshal 

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

type ScriptingOptions_Golang 

type ScriptingOptions_Golang struct {
	Golang *ScriptingOptionsGolang `protobuf:"bytes,1,opt,name=golang,proto3,oneof"`
}

type ScriptingOptions_Python 

type ScriptingOptions_Python struct {
	Python *ScriptingOptionsPython `protobuf:"bytes,2,opt,name=python,proto3,oneof"`
}

type ScriptingOptions_Roswell 

type ScriptingOptions_Roswell struct {
	Roswell *ScriptingOptionsRoswell `protobuf:"bytes,3,opt,name=roswell,proto3,oneof"`
}

type SignalProcess 

type SignalProcess struct {
	ProcessID            *JasperProcessID `protobuf:"bytes,1,opt,name=ProcessID,proto3" json:"ProcessID,omitempty"`
	Signal               Signals          `protobuf:"varint,2,opt,name=signal,proto3,enum=jasper.Signals" json:"signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SignalProcess) Descriptor 

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

func (*SignalProcess) GetProcessID 

func (m *SignalProcess) GetProcessID() *JasperProcessID

func (*SignalProcess) GetSignal 

func (m *SignalProcess) GetSignal() Signals

func (*SignalProcess) ProtoMessage 

func (*SignalProcess) ProtoMessage()

func (*SignalProcess) Reset 

func (m *SignalProcess) Reset()

func (*SignalProcess) String 

func (m *SignalProcess) String() string

func (*SignalProcess) XXX_DiscardUnknown 

func (m *SignalProcess) XXX_DiscardUnknown()

func (*SignalProcess) XXX_Marshal 

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

func (*SignalProcess) XXX_Merge 

func (m *SignalProcess) XXX_Merge(src proto.Message)

func (*SignalProcess) XXX_Size 

func (m *SignalProcess) XXX_Size() int

func (*SignalProcess) XXX_Unmarshal 

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

type SignalTriggerID 

type SignalTriggerID int32
const (
	SignalTriggerID_NONE             SignalTriggerID = 0
	SignalTriggerID_CLEANTERMINATION SignalTriggerID = 1
)

func ConvertSignalTriggerID 

func ConvertSignalTriggerID(id jasper.SignalTriggerID) SignalTriggerID

ConvertSignalTriggerID takes a Jasper SignalTriggerID and returns an equivalent protobuf RPC SignalTriggerID. ConvertSignalTrigger is the inverse of (SignalTriggerID) Export().

func (SignalTriggerID) EnumDescriptor 

func (SignalTriggerID) EnumDescriptor() ([]byte, []int)

func (SignalTriggerID) Export 

func (t SignalTriggerID) Export() jasper.SignalTriggerID

Export takes a protobuf RPC SignalTriggerID and returns the analogous Jasper SignalTriggerID.

func (SignalTriggerID) String 

func (x SignalTriggerID) String() string

type SignalTriggerParams 

type SignalTriggerParams struct {
	ProcessID            *JasperProcessID `protobuf:"bytes,1,opt,name=processID,proto3" json:"processID,omitempty"`
	SignalTriggerID      SignalTriggerID  `protobuf:"varint,2,opt,name=signalTriggerID,proto3,enum=jasper.SignalTriggerID" json:"signalTriggerID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func ConvertSignalTriggerParams 

func ConvertSignalTriggerParams(jasperProcessID string, signalTriggerID jasper.SignalTriggerID) *SignalTriggerParams

ConvertSignalTriggerParams takes a Jasper process ID and a SignalTriggerID and returns an equivalent protobuf RPC SignalTriggerParams struct. ConvertSignalTriggerParams is the inverse of (SignalTriggerParams) Export().

func (*SignalTriggerParams) Descriptor 

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

func (SignalTriggerParams) Export 

func (t SignalTriggerParams) Export() (string, jasper.SignalTriggerID)

Export takes a protobuf RPC SignalTriggerParams struct and returns the analogous Jasper process ID and SignalTriggerID.

func (*SignalTriggerParams) GetProcessID 

func (m *SignalTriggerParams) GetProcessID() *JasperProcessID

func (*SignalTriggerParams) GetSignalTriggerID 

func (m *SignalTriggerParams) GetSignalTriggerID() SignalTriggerID

func (*SignalTriggerParams) ProtoMessage 

func (*SignalTriggerParams) ProtoMessage()

func (*SignalTriggerParams) Reset 

func (m *SignalTriggerParams) Reset()

func (*SignalTriggerParams) String 

func (m *SignalTriggerParams) String() string

func (*SignalTriggerParams) XXX_DiscardUnknown 

func (m *SignalTriggerParams) XXX_DiscardUnknown()

func (*SignalTriggerParams) XXX_Marshal 

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

func (*SignalTriggerParams) XXX_Merge 

func (m *SignalTriggerParams) XXX_Merge(src proto.Message)

func (*SignalTriggerParams) XXX_Size 

func (m *SignalTriggerParams) XXX_Size() int

func (*SignalTriggerParams) XXX_Unmarshal 

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

type Signals 

type Signals int32
const (
	Signals_UNKNOWN   Signals = 0
	Signals_TERMINATE Signals = 1
	Signals_KILL      Signals = 2
	Signals_HANGUP    Signals = 3
	Signals_INIT      Signals = 4
	Signals_USER1     Signals = 5
	Signals_USER2     Signals = 6
	Signals_ABRT      Signals = 7
)

func ConvertSignal 

func ConvertSignal(s syscall.Signal) Signals

ConvertSignal takes a syscall.Signal and returns an equivalent protobuf RPC Signals struct. ConvertSignals is the inverse of (Signals) Export().

func (Signals) EnumDescriptor 

func (Signals) EnumDescriptor() ([]byte, []int)

func (Signals) Export 

func (s Signals) Export() syscall.Signal

Export takes a protobuf RPC Signals struct and returns the analogous syscall.Signal.

func (Signals) String 

func (x Signals) String() string

type SplunkInfo 

type SplunkInfo struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Channel              string   `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ConvertSplunkInfo 

func ConvertSplunkInfo(opts splunk.ConnectionInfo) *SplunkInfo

ConvertSplunkInfo takes a grip send.SplunkConnectionInfo and returns the analogous protobuf RPC SplunkInfo struct. ConvertSplunkInfo is the inverse of (SplunkInfo) Export().

func (*SplunkInfo) Descriptor 

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

func (SplunkInfo) Export 

func (opts SplunkInfo) Export() splunk.ConnectionInfo

Export takes a protobuf RPC SplunkInfo struct and returns the analogous grip send.SplunkConnectionInfo struct.

func (*SplunkInfo) GetChannel 

func (m *SplunkInfo) GetChannel() string

func (*SplunkInfo) GetToken 

func (m *SplunkInfo) GetToken() string

func (*SplunkInfo) GetUrl 

func (m *SplunkInfo) GetUrl() string

func (*SplunkInfo) ProtoMessage 

func (*SplunkInfo) ProtoMessage()

func (*SplunkInfo) Reset 

func (m *SplunkInfo) Reset()

func (*SplunkInfo) String 

func (m *SplunkInfo) String() string

func (*SplunkInfo) XXX_DiscardUnknown 

func (m *SplunkInfo) XXX_DiscardUnknown()

func (*SplunkInfo) XXX_Marshal 

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

func (*SplunkInfo) XXX_Merge 

func (m *SplunkInfo) XXX_Merge(src proto.Message)

func (*SplunkInfo) XXX_Size 

func (m *SplunkInfo) XXX_Size() int

func (*SplunkInfo) XXX_Unmarshal 

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

type SplunkLoggerOptions 

type SplunkLoggerOptions struct {
	Splunk               *SplunkInfo  `protobuf:"bytes,1,opt,name=splunk,proto3" json:"splunk,omitempty"`
	Base                 *BaseOptions `protobuf:"bytes,2,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SplunkLoggerOptions) Descriptor 

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

func (SplunkLoggerOptions) Export 

func (opts SplunkLoggerOptions) Export() options.LoggerProducer

Export takes a protobuf RPC SplunkLoggerOptions struct and returns the analogous Jasper options.LoggerProducer.

func (*SplunkLoggerOptions) GetBase 

func (m *SplunkLoggerOptions) GetBase() *BaseOptions

func (*SplunkLoggerOptions) GetSplunk 

func (m *SplunkLoggerOptions) GetSplunk() *SplunkInfo

func (*SplunkLoggerOptions) ProtoMessage 

func (*SplunkLoggerOptions) ProtoMessage()

func (*SplunkLoggerOptions) Reset 

func (m *SplunkLoggerOptions) Reset()

func (*SplunkLoggerOptions) String 

func (m *SplunkLoggerOptions) String() string

func (*SplunkLoggerOptions) XXX_DiscardUnknown 

func (m *SplunkLoggerOptions) XXX_DiscardUnknown()

func (*SplunkLoggerOptions) XXX_Marshal 

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

func (*SplunkLoggerOptions) XXX_Merge 

func (m *SplunkLoggerOptions) XXX_Merge(src proto.Message)

func (*SplunkLoggerOptions) XXX_Size 

func (m *SplunkLoggerOptions) XXX_Size() int

func (*SplunkLoggerOptions) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	HostId               string   `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Active               bool     `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetActive 

func (m *StatusResponse) GetActive() bool

func (*StatusResponse) GetHostId 

func (m *StatusResponse) GetHostId() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

func (m *StatusResponse) XXX_Merge(src proto.Message)

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type TagName 

type TagName struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TagName) Descriptor 

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

func (*TagName) GetValue 

func (m *TagName) GetValue() string

func (*TagName) ProtoMessage 

func (*TagName) ProtoMessage()

func (*TagName) Reset 

func (m *TagName) Reset()

func (*TagName) String 

func (m *TagName) String() string

func (*TagName) XXX_DiscardUnknown 

func (m *TagName) XXX_DiscardUnknown()

func (*TagName) XXX_Marshal 

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

func (*TagName) XXX_Merge 

func (m *TagName) XXX_Merge(src proto.Message)

func (*TagName) XXX_Size 

func (m *TagName) XXX_Size() int

func (*TagName) XXX_Unmarshal 

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

type WriteFileInfo 

type WriteFileInfo struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Content              []byte   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Append               bool     `protobuf:"varint,4,opt,name=append,proto3" json:"append,omitempty"`
	Perm                 uint32   `protobuf:"varint,3,opt,name=perm,proto3" json:"perm,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ConvertWriteFileOptions 

func ConvertWriteFileOptions(opts options.WriteFile) *WriteFileInfo

ConvertWriteFileOptions takes an options.WriteFile struct and returns an equivalent protobuf RPC WriteFileInfo struct. ConvertWriteFileOptions is the inverse of (*WriteFileInfo) Export().

func (*WriteFileInfo) Descriptor 

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

func (*WriteFileInfo) Export 

func (opts *WriteFileInfo) Export() options.WriteFile

Export takes a protobuf RPC WriteFileInfo struct and returns the analogous options.WriteFile struct.

func (*WriteFileInfo) GetAppend 

func (m *WriteFileInfo) GetAppend() bool

func (*WriteFileInfo) GetContent 

func (m *WriteFileInfo) GetContent() []byte

func (*WriteFileInfo) GetPath 

func (m *WriteFileInfo) GetPath() string

func (*WriteFileInfo) GetPerm 

func (m *WriteFileInfo) GetPerm() uint32

func (*WriteFileInfo) ProtoMessage 

func (*WriteFileInfo) ProtoMessage()

func (*WriteFileInfo) Reset 

func (m *WriteFileInfo) Reset()

func (*WriteFileInfo) String 

func (m *WriteFileInfo) String() string

func (*WriteFileInfo) XXX_DiscardUnknown 

func (m *WriteFileInfo) XXX_DiscardUnknown()

func (*WriteFileInfo) XXX_Marshal 

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

func (*WriteFileInfo) XXX_Merge 

func (m *WriteFileInfo) XXX_Merge(src proto.Message)

func (*WriteFileInfo) XXX_Size 

func (m *WriteFileInfo) XXX_Size() int

func (*WriteFileInfo) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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