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

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

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

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

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

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

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

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 (*ScriptingHarnessBuildResponse) GetPath

func (*ScriptingHarnessBuildResponse) ProtoMessage

func (*ScriptingHarnessBuildResponse) ProtoMessage()

func (*ScriptingHarnessBuildResponse) Reset

func (m *ScriptingHarnessBuildResponse) Reset()

func (*ScriptingHarnessBuildResponse) 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 (*ScriptingHarnessRunScriptArgs) GetScript

func (m *ScriptingHarnessRunScriptArgs) GetScript() string

func (*ScriptingHarnessRunScriptArgs) ProtoMessage

func (*ScriptingHarnessRunScriptArgs) ProtoMessage()

func (*ScriptingHarnessRunScriptArgs) Reset

func (m *ScriptingHarnessRunScriptArgs) Reset()

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

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 (*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 (*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

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

func (*ScriptingHarnessTestResponse) GetOutcome

func (*ScriptingHarnessTestResponse) GetResults

func (*ScriptingHarnessTestResponse) ProtoMessage

func (*ScriptingHarnessTestResponse) ProtoMessage()

func (*ScriptingHarnessTestResponse) Reset

func (m *ScriptingHarnessTestResponse) Reset()

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

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

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL