api

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Feb 13, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Overview

Package api contains the RSCA protobuf files and definitions.

Index

Constants

View Source
const (
	Admin_ListHosts_FullMethodName   = "/rsca.api.Admin/ListHosts"
	Admin_RemoveHost_FullMethodName  = "/rsca.api.Admin/RemoveHost"
	Admin_TriggerAll_FullMethodName  = "/rsca.api.Admin/TriggerAll"
	Admin_TriggerInfo_FullMethodName = "/rsca.api.Admin/TriggerInfo"
)
View Source
const (
	RSCA_Pipe_FullMethodName = "/rsca.api.RSCA/Pipe"
)

Variables

View Source
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "WARNING",
		2: "CRITICAL",
		3: "UNKNOWN",
	}
	Status_value = map[string]int32{
		"OK":       0,
		"WARNING":  1,
		"CRITICAL": 2,
		"UNKNOWN":  3,
	}
)

Enum value maps for Status.

View Source
var (
	CheckType_name = map[int32]string{
		0: "HOST",
		1: "SERVICE",
	}
	CheckType_value = map[string]int32{
		"HOST":    0,
		"SERVICE": 1,
	}
)

Enum value maps for CheckType.

View Source
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rsca.api.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoveHost",
			Handler:    _Admin_RemoveHost_Handler,
		},
		{
			MethodName: "TriggerAll",
			Handler:    _Admin_TriggerAll_Handler,
		},
		{
			MethodName: "TriggerInfo",
			Handler:    _Admin_TriggerInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListHosts",
			Handler:       _Admin_ListHosts_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "github.com/na4ma4/rsca/api/admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_github_com_na4ma4_rsca_api_admin_proto protoreflect.FileDescriptor
View Source
var File_github_com_na4ma4_rsca_api_api_proto protoreflect.FileDescriptor
View Source
var File_github_com_na4ma4_rsca_api_common_proto protoreflect.FileDescriptor
View Source
var RSCA_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rsca.api.RSCA",
	HandlerType: (*RSCAServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Pipe",
			Handler:       _RSCA_Pipe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/na4ma4/rsca/api/api.proto",
}

RSCA_ServiceDesc is the grpc.ServiceDesc for RSCA service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAdminServer

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterRSCAServer

func RegisterRSCAServer(s grpc.ServiceRegistrar, srv RSCAServer)

Types

type AdminClient

type AdminClient interface {
	ListHosts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Admin_ListHostsClient, error)
	RemoveHost(ctx context.Context, in *RemoveHostRequest, opts ...grpc.CallOption) (*RemoveHostResponse, error)
	TriggerAll(ctx context.Context, in *Members, opts ...grpc.CallOption) (*TriggerAllResponse, error)
	TriggerInfo(ctx context.Context, in *Members, opts ...grpc.CallOption) (*TriggerInfoResponse, error)
}

AdminClient is the client API for Admin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAdminClient

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer

type AdminServer interface {
	ListHosts(*Empty, Admin_ListHostsServer) error
	RemoveHost(context.Context, *RemoveHostRequest) (*RemoveHostResponse, error)
	TriggerAll(context.Context, *Members) (*TriggerAllResponse, error)
	TriggerInfo(context.Context, *Members) (*TriggerInfoResponse, error)
}

AdminServer is the server API for Admin service. All implementations should embed UnimplementedAdminServer for forward compatibility

type Admin_ListHostsClient

type Admin_ListHostsClient interface {
	Recv() (*Member, error)
	grpc.ClientStream
}

type Admin_ListHostsServer

type Admin_ListHostsServer interface {
	Send(*Member) error
	grpc.ServerStream
}

type CheckType

type CheckType int32
const (
	CheckType_HOST    CheckType = 0
	CheckType_SERVICE CheckType = 1
)

func (CheckType) Descriptor

func (CheckType) Descriptor() protoreflect.EnumDescriptor

func (CheckType) Enum

func (x CheckType) Enum() *CheckType

func (CheckType) EnumDescriptor deprecated

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

Deprecated: Use CheckType.Descriptor instead.

func (CheckType) Number

func (x CheckType) Number() protoreflect.EnumNumber

func (CheckType) String

func (x CheckType) String() string

func (CheckType) Type

type Empty

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type Envelope

type Envelope struct {
	Sender    *Member  `protobuf:"bytes,10,opt,name=sender,proto3" json:"sender,omitempty"`
	Recipient *Members `protobuf:"bytes,11,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// contains filtered or unexported fields
}

func (*Envelope) Descriptor deprecated

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetRecipient

func (x *Envelope) GetRecipient() *Members

func (*Envelope) GetSender

func (x *Envelope) GetSender() *Member

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset

func (x *Envelope) Reset()

func (*Envelope) String

func (x *Envelope) String() string

type EventMessage

type EventMessage struct {
	Hostname         string                 `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Type             CheckType              `protobuf:"varint,2,opt,name=type,proto3,enum=rsca.api.CheckType" json:"type,omitempty"`
	Check            string                 `protobuf:"bytes,3,opt,name=check,proto3" json:"check,omitempty"`
	Status           Status                 `protobuf:"varint,4,opt,name=status,proto3,enum=rsca.api.Status" json:"status,omitempty"`
	Output           string                 `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	OutputError      string                 `protobuf:"bytes,10,opt,name=output_error,json=outputError,proto3" json:"output_error,omitempty"`
	Perfdata         string                 `protobuf:"bytes,6,opt,name=perfdata,proto3" json:"perfdata,omitempty"`
	RequestTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=request_timestamp,json=requestTimestamp,proto3" json:"request_timestamp,omitempty"`
	Retries          int32                  `protobuf:"varint,8,opt,name=retries,proto3" json:"retries,omitempty"`
	Id               string                 `protobuf:"bytes,9,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMessage) Descriptor deprecated

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

Deprecated: Use EventMessage.ProtoReflect.Descriptor instead.

func (*EventMessage) GetCheck

func (x *EventMessage) GetCheck() string

func (*EventMessage) GetHostname

func (x *EventMessage) GetHostname() string

func (*EventMessage) GetId

func (x *EventMessage) GetId() string

func (*EventMessage) GetOutput

func (x *EventMessage) GetOutput() string

func (*EventMessage) GetOutputError added in v0.4.0

func (x *EventMessage) GetOutputError() string

func (*EventMessage) GetPerfdata

func (x *EventMessage) GetPerfdata() string

func (*EventMessage) GetRequestTimestamp

func (x *EventMessage) GetRequestTimestamp() *timestamppb.Timestamp

func (*EventMessage) GetRetries

func (x *EventMessage) GetRetries() int32

func (*EventMessage) GetStatus

func (x *EventMessage) GetStatus() Status

func (*EventMessage) GetType

func (x *EventMessage) GetType() CheckType

func (*EventMessage) ProtoMessage

func (*EventMessage) ProtoMessage()

func (*EventMessage) ProtoReflect

func (x *EventMessage) ProtoReflect() protoreflect.Message

func (*EventMessage) Reset

func (x *EventMessage) Reset()

func (*EventMessage) String

func (x *EventMessage) String() string

type InfoStat added in v0.5.0

type InfoStat struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Hostname  string                 `protobuf:"bytes,21,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Uptime    uint64                 `protobuf:"varint,22,opt,name=uptime,proto3" json:"uptime,omitempty"`
	BootTime  uint64                 `protobuf:"varint,23,opt,name=boot_time,json=bootTime,proto3" json:"boot_time,omitempty"`
	// number of processes
	Procs uint64 `protobuf:"varint,24,opt,name=procs,proto3" json:"procs,omitempty"`
	// ex: freebsd, linux
	Os string `protobuf:"bytes,25,opt,name=os,proto3" json:"os,omitempty"`
	// ex: ubuntu, linuxmint
	Platform string `protobuf:"bytes,26,opt,name=platform,proto3" json:"platform,omitempty"`
	// ex: debian, rhel
	PlatformFamily string `protobuf:"bytes,27,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	// version of the complete OS
	PlatformVersion string `protobuf:"bytes,28,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	// version of the OS kernel (if available)
	KernelVersion string `protobuf:"bytes,29,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	// native cpu architecture queried at runtime, as returned by `uname -m` or empty string in case of error
	KernelArch string `protobuf:"bytes,30,opt,name=kernel_arch,json=kernelArch,proto3" json:"kernel_arch,omitempty"`
	VirtSystem string `protobuf:"bytes,31,opt,name=virt_system,json=virtSystem,proto3" json:"virt_system,omitempty"`
	// guest or host
	VirtRole string `protobuf:"bytes,32,opt,name=virt_role,json=virtRole,proto3" json:"virt_role,omitempty"`
	// ex: uuid
	HostId string `protobuf:"bytes,33,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

func InfoWithContext added in v0.5.0

func InfoWithContext(ctx context.Context, ts time.Time) (*InfoStat, error)

InfoWithContext calls shirou/gopsutil InfoWithContext and returns a native InfoStat for protobuf.

func (*InfoStat) Descriptor deprecated added in v0.5.0

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

Deprecated: Use InfoStat.ProtoReflect.Descriptor instead.

func (*InfoStat) GetBootTime added in v0.5.0

func (x *InfoStat) GetBootTime() uint64

func (*InfoStat) GetHostId added in v0.5.0

func (x *InfoStat) GetHostId() string

func (*InfoStat) GetHostname added in v0.5.0

func (x *InfoStat) GetHostname() string

func (*InfoStat) GetKernelArch added in v0.5.0

func (x *InfoStat) GetKernelArch() string

func (*InfoStat) GetKernelVersion added in v0.5.0

func (x *InfoStat) GetKernelVersion() string

func (*InfoStat) GetOs added in v0.5.0

func (x *InfoStat) GetOs() string

func (*InfoStat) GetPlatform added in v0.5.0

func (x *InfoStat) GetPlatform() string

func (*InfoStat) GetPlatformFamily added in v0.5.0

func (x *InfoStat) GetPlatformFamily() string

func (*InfoStat) GetPlatformVersion added in v0.5.0

func (x *InfoStat) GetPlatformVersion() string

func (*InfoStat) GetProcs added in v0.5.0

func (x *InfoStat) GetProcs() uint64

func (*InfoStat) GetTimestamp added in v0.5.0

func (x *InfoStat) GetTimestamp() *timestamppb.Timestamp

func (*InfoStat) GetUptime added in v0.5.0

func (x *InfoStat) GetUptime() uint64

func (*InfoStat) GetVirtRole added in v0.5.0

func (x *InfoStat) GetVirtRole() string

func (*InfoStat) GetVirtSystem added in v0.5.0

func (x *InfoStat) GetVirtSystem() string

func (*InfoStat) ProtoMessage added in v0.5.0

func (*InfoStat) ProtoMessage()

func (*InfoStat) ProtoReflect added in v0.5.0

func (x *InfoStat) ProtoReflect() protoreflect.Message

func (*InfoStat) Reset added in v0.5.0

func (x *InfoStat) Reset()

func (*InfoStat) String added in v0.5.0

func (x *InfoStat) String() string

type Member

type Member struct {
	Id           string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	InternalId   string                 `protobuf:"bytes,2,opt,name=internal_id,json=internalId,proto3" json:"internal_id,omitempty"`
	Name         string                 `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	Capability   []string               `protobuf:"bytes,11,rep,name=capability,proto3" json:"capability,omitempty"`
	Tag          []string               `protobuf:"bytes,12,rep,name=tag,proto3" json:"tag,omitempty"`
	Service      []string               `protobuf:"bytes,13,rep,name=service,proto3" json:"service,omitempty"`
	Version      string                 `protobuf:"bytes,90,opt,name=version,proto3" json:"version,omitempty"`
	GitHash      string                 `protobuf:"bytes,91,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	BuildDate    string                 `protobuf:"bytes,92,opt,name=build_date,json=buildDate,proto3" json:"build_date,omitempty"`
	LastSeen     *timestamppb.Timestamp `protobuf:"bytes,100,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	PingLatency  *durationpb.Duration   `protobuf:"bytes,102,opt,name=ping_latency,json=pingLatency,proto3" json:"ping_latency,omitempty"`
	InfoStat     *InfoStat              `protobuf:"bytes,200,opt,name=info_stat,json=infoStat,proto3" json:"info_stat,omitempty"`
	SystemStart  *timestamppb.Timestamp `protobuf:"bytes,201,opt,name=system_start,json=systemStart,proto3" json:"system_start,omitempty"`
	ProcessStart *timestamppb.Timestamp `protobuf:"bytes,202,opt,name=process_start,json=processStart,proto3" json:"process_start,omitempty"`
	Active       bool                   `protobuf:"varint,203,opt,name=active,proto3" json:"active,omitempty"`
	// Only used in rendering host lists, not transferred over the wire.
	LastSeenAgo string `protobuf:"bytes,1001,opt,name=last_seen_ago,json=lastSeenAgo,proto3" json:"last_seen_ago,omitempty"`
	Latency     string `protobuf:"bytes,1003,opt,name=latency,proto3" json:"latency,omitempty"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetActive added in v0.5.8

func (x *Member) GetActive() bool

func (*Member) GetBuildDate added in v0.3.0

func (x *Member) GetBuildDate() string

func (*Member) GetCapability

func (x *Member) GetCapability() []string

func (*Member) GetGitHash added in v0.3.0

func (x *Member) GetGitHash() string

func (*Member) GetId

func (x *Member) GetId() string

func (*Member) GetInfoStat added in v0.5.0

func (x *Member) GetInfoStat() *InfoStat

func (*Member) GetInternalId

func (x *Member) GetInternalId() string

func (*Member) GetLastSeen

func (x *Member) GetLastSeen() *timestamppb.Timestamp

func (*Member) GetLastSeenAgo

func (x *Member) GetLastSeenAgo() string

func (*Member) GetLatency

func (x *Member) GetLatency() string

func (*Member) GetName

func (x *Member) GetName() string

func (*Member) GetPingLatency

func (x *Member) GetPingLatency() *durationpb.Duration

func (*Member) GetProcessStart added in v0.5.0

func (x *Member) GetProcessStart() *timestamppb.Timestamp

func (*Member) GetService

func (x *Member) GetService() []string

func (*Member) GetSystemStart added in v0.5.0

func (x *Member) GetSystemStart() *timestamppb.Timestamp

func (*Member) GetTag

func (x *Member) GetTag() []string

func (*Member) GetVersion added in v0.3.0

func (x *Member) GetVersion() string

func (*Member) IsMatch added in v0.5.6

func (x *Member) IsMatch(query string) bool

IsMatch returns if a member matches a supplied query string

Query strings can start or end in a * or % to indicate wildcard matching.

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) ProtoReflect

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset

func (x *Member) Reset()

func (*Member) String

func (x *Member) String() string

type MemberUpdateMessage added in v0.5.0

type MemberUpdateMessage struct {
	Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberUpdateMessage) Descriptor deprecated added in v0.5.0

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

Deprecated: Use MemberUpdateMessage.ProtoReflect.Descriptor instead.

func (*MemberUpdateMessage) GetMember added in v0.5.0

func (x *MemberUpdateMessage) GetMember() *Member

func (*MemberUpdateMessage) ProtoMessage added in v0.5.0

func (*MemberUpdateMessage) ProtoMessage()

func (*MemberUpdateMessage) ProtoReflect added in v0.5.0

func (x *MemberUpdateMessage) ProtoReflect() protoreflect.Message

func (*MemberUpdateMessage) Reset added in v0.5.0

func (x *MemberUpdateMessage) Reset()

func (*MemberUpdateMessage) String added in v0.5.0

func (x *MemberUpdateMessage) String() string

type Members

type Members struct {
	Id         []string `protobuf:"bytes,10,rep,name=id,proto3" json:"id,omitempty"`
	Name       []string `protobuf:"bytes,11,rep,name=name,proto3" json:"name,omitempty"`
	Capability []string `protobuf:"bytes,12,rep,name=capability,proto3" json:"capability,omitempty"`
	Tag        []string `protobuf:"bytes,13,rep,name=tag,proto3" json:"tag,omitempty"`
	Service    []string `protobuf:"bytes,14,rep,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func MembersByID

func MembersByID(id string) *Members

MembersByID returns a member from a supplied id.

func RecipientBySender

func RecipientBySender(in *Member) *Members

RecipientBySender converts a Envelope.Sender to Envelope.Recipient.

func (*Members) Descriptor deprecated

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

Deprecated: Use Members.ProtoReflect.Descriptor instead.

func (*Members) GetCapability

func (x *Members) GetCapability() []string

func (*Members) GetId

func (x *Members) GetId() []string

func (*Members) GetName

func (x *Members) GetName() []string

func (*Members) GetService

func (x *Members) GetService() []string

func (*Members) GetTag

func (x *Members) GetTag() []string

func (*Members) ProtoMessage

func (*Members) ProtoMessage()

func (*Members) ProtoReflect

func (x *Members) ProtoReflect() protoreflect.Message

func (*Members) Reset

func (x *Members) Reset()

func (*Members) String

func (x *Members) String() string

type Message

type Message struct {
	Envelope *Envelope `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	// Types that are assignable to Message:
	//
	//	*Message_RegisterMessage
	//	*Message_PingMessage
	//	*Message_PongMessage
	//	*Message_EventMessage
	//	*Message_TriggerAllMessage
	//	*Message_RepeatRegistrationMessage
	//	*Message_MemberUpdateMessage
	Message isMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetEnvelope

func (x *Message) GetEnvelope() *Envelope

func (*Message) GetEventMessage

func (x *Message) GetEventMessage() *EventMessage

func (*Message) GetMemberUpdateMessage added in v0.5.0

func (x *Message) GetMemberUpdateMessage() *MemberUpdateMessage

func (*Message) GetMessage

func (m *Message) GetMessage() isMessage_Message

func (*Message) GetPingMessage

func (x *Message) GetPingMessage() *PingMessage

func (*Message) GetPongMessage

func (x *Message) GetPongMessage() *PongMessage

func (*Message) GetRegisterMessage

func (x *Message) GetRegisterMessage() *RegisterMessage

func (*Message) GetRepeatRegistrationMessage added in v0.5.0

func (x *Message) GetRepeatRegistrationMessage() *RepeatRegistrationMessage

func (*Message) GetTriggerAllMessage added in v0.5.0

func (x *Message) GetTriggerAllMessage() *TriggerAllMessage

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type Message_EventMessage

type Message_EventMessage struct {
	EventMessage *EventMessage `protobuf:"bytes,103,opt,name=event_message,json=eventMessage,proto3,oneof"`
}

type Message_MemberUpdateMessage added in v0.5.0

type Message_MemberUpdateMessage struct {
	MemberUpdateMessage *MemberUpdateMessage `protobuf:"bytes,106,opt,name=member_update_message,json=memberUpdateMessage,proto3,oneof"`
}

type Message_PingMessage

type Message_PingMessage struct {
	PingMessage *PingMessage `protobuf:"bytes,101,opt,name=ping_message,json=pingMessage,proto3,oneof"`
}

type Message_PongMessage

type Message_PongMessage struct {
	PongMessage *PongMessage `protobuf:"bytes,102,opt,name=pong_message,json=pongMessage,proto3,oneof"`
}

type Message_RegisterMessage

type Message_RegisterMessage struct {
	RegisterMessage *RegisterMessage `protobuf:"bytes,100,opt,name=register_message,json=registerMessage,proto3,oneof"`
}

type Message_RepeatRegistrationMessage added in v0.5.0

type Message_RepeatRegistrationMessage struct {
	RepeatRegistrationMessage *RepeatRegistrationMessage `protobuf:"bytes,105,opt,name=repeat_registration_message,json=repeatRegistrationMessage,proto3,oneof"`
}

type Message_TriggerAllMessage added in v0.5.0

type Message_TriggerAllMessage struct {
	TriggerAllMessage *TriggerAllMessage `protobuf:"bytes,104,opt,name=trigger_all_message,json=triggerAllMessage,proto3,oneof"`
}

type PingMessage

type PingMessage struct {
	Id       string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId string                 `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Ts       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PingMessage) Descriptor deprecated

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

Deprecated: Use PingMessage.ProtoReflect.Descriptor instead.

func (*PingMessage) GetId

func (x *PingMessage) GetId() string

func (*PingMessage) GetStreamId

func (x *PingMessage) GetStreamId() string

func (*PingMessage) GetTs

func (x *PingMessage) GetTs() *timestamppb.Timestamp

func (*PingMessage) ProtoMessage

func (*PingMessage) ProtoMessage()

func (*PingMessage) ProtoReflect

func (x *PingMessage) ProtoReflect() protoreflect.Message

func (*PingMessage) Reset

func (x *PingMessage) Reset()

func (*PingMessage) String

func (x *PingMessage) String() string

type PongMessage

type PongMessage struct {
	Id       string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId string                 `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Ts       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PongMessage) Descriptor deprecated

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

Deprecated: Use PongMessage.ProtoReflect.Descriptor instead.

func (*PongMessage) GetId

func (x *PongMessage) GetId() string

func (*PongMessage) GetStreamId

func (x *PongMessage) GetStreamId() string

func (*PongMessage) GetTs

func (x *PongMessage) GetTs() *timestamppb.Timestamp

func (*PongMessage) ProtoMessage

func (*PongMessage) ProtoMessage()

func (*PongMessage) ProtoReflect

func (x *PongMessage) ProtoReflect() protoreflect.Message

func (*PongMessage) Reset

func (x *PongMessage) Reset()

func (*PongMessage) String

func (x *PongMessage) String() string

type RSCAClient

type RSCAClient interface {
	Pipe(ctx context.Context, opts ...grpc.CallOption) (RSCA_PipeClient, error)
}

RSCAClient is the client API for RSCA service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRSCAClient

func NewRSCAClient(cc grpc.ClientConnInterface) RSCAClient

type RSCAServer

type RSCAServer interface {
	Pipe(RSCA_PipeServer) error
}

RSCAServer is the server API for RSCA service. All implementations should embed UnimplementedRSCAServer for forward compatibility

type RSCA_PipeClient

type RSCA_PipeClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type RSCA_PipeServer

type RSCA_PipeServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type RegisterMessage

type RegisterMessage struct {
	Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMessage) Descriptor deprecated

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

Deprecated: Use RegisterMessage.ProtoReflect.Descriptor instead.

func (*RegisterMessage) GetMember

func (x *RegisterMessage) GetMember() *Member

func (*RegisterMessage) ProtoMessage

func (*RegisterMessage) ProtoMessage()

func (*RegisterMessage) ProtoReflect

func (x *RegisterMessage) ProtoReflect() protoreflect.Message

func (*RegisterMessage) Reset

func (x *RegisterMessage) Reset()

func (*RegisterMessage) String

func (x *RegisterMessage) String() string

type RemoveHostRequest added in v0.5.9

type RemoveHostRequest struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveHostRequest) Descriptor deprecated added in v0.5.9

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

Deprecated: Use RemoveHostRequest.ProtoReflect.Descriptor instead.

func (*RemoveHostRequest) GetNames added in v0.5.9

func (x *RemoveHostRequest) GetNames() []string

func (*RemoveHostRequest) ProtoMessage added in v0.5.9

func (*RemoveHostRequest) ProtoMessage()

func (*RemoveHostRequest) ProtoReflect added in v0.5.9

func (x *RemoveHostRequest) ProtoReflect() protoreflect.Message

func (*RemoveHostRequest) Reset added in v0.5.9

func (x *RemoveHostRequest) Reset()

func (*RemoveHostRequest) String added in v0.5.9

func (x *RemoveHostRequest) String() string

type RemoveHostResponse added in v0.5.9

type RemoveHostResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveHostResponse) Descriptor deprecated added in v0.5.9

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

Deprecated: Use RemoveHostResponse.ProtoReflect.Descriptor instead.

func (*RemoveHostResponse) GetNames added in v0.5.9

func (x *RemoveHostResponse) GetNames() []string

func (*RemoveHostResponse) ProtoMessage added in v0.5.9

func (*RemoveHostResponse) ProtoMessage()

func (*RemoveHostResponse) ProtoReflect added in v0.5.9

func (x *RemoveHostResponse) ProtoReflect() protoreflect.Message

func (*RemoveHostResponse) Reset added in v0.5.9

func (x *RemoveHostResponse) Reset()

func (*RemoveHostResponse) String added in v0.5.9

func (x *RemoveHostResponse) String() string

type RepeatRegistrationMessage added in v0.5.0

type RepeatRegistrationMessage struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RepeatRegistrationMessage) Descriptor deprecated added in v0.5.0

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

Deprecated: Use RepeatRegistrationMessage.ProtoReflect.Descriptor instead.

func (*RepeatRegistrationMessage) GetId added in v0.5.0

func (x *RepeatRegistrationMessage) GetId() string

func (*RepeatRegistrationMessage) ProtoMessage added in v0.5.0

func (*RepeatRegistrationMessage) ProtoMessage()

func (*RepeatRegistrationMessage) ProtoReflect added in v0.5.0

func (*RepeatRegistrationMessage) Reset added in v0.5.0

func (x *RepeatRegistrationMessage) Reset()

func (*RepeatRegistrationMessage) String added in v0.5.0

func (x *RepeatRegistrationMessage) String() string

type Status

type Status int32
const (
	Status_OK       Status = 0
	Status_WARNING  Status = 1
	Status_CRITICAL Status = 2
	Status_UNKNOWN  Status = 3
)

func ExitCodeToStatus

func ExitCodeToStatus(exitCode int) Status

ExitCodeToStatus converts a returned exit code to a Status.

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) Type

func (Status) Type() protoreflect.EnumType

type TriggerAllMessage added in v0.5.0

type TriggerAllMessage struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerAllMessage) Descriptor deprecated added in v0.5.0

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

Deprecated: Use TriggerAllMessage.ProtoReflect.Descriptor instead.

func (*TriggerAllMessage) GetId added in v0.5.0

func (x *TriggerAllMessage) GetId() string

func (*TriggerAllMessage) ProtoMessage added in v0.5.0

func (*TriggerAllMessage) ProtoMessage()

func (*TriggerAllMessage) ProtoReflect added in v0.5.0

func (x *TriggerAllMessage) ProtoReflect() protoreflect.Message

func (*TriggerAllMessage) Reset added in v0.5.0

func (x *TriggerAllMessage) Reset()

func (*TriggerAllMessage) String added in v0.5.0

func (x *TriggerAllMessage) String() string

type TriggerAllResponse

type TriggerAllResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerAllResponse) Descriptor deprecated

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

Deprecated: Use TriggerAllResponse.ProtoReflect.Descriptor instead.

func (*TriggerAllResponse) GetNames

func (x *TriggerAllResponse) GetNames() []string

func (*TriggerAllResponse) ProtoMessage

func (*TriggerAllResponse) ProtoMessage()

func (*TriggerAllResponse) ProtoReflect

func (x *TriggerAllResponse) ProtoReflect() protoreflect.Message

func (*TriggerAllResponse) Reset

func (x *TriggerAllResponse) Reset()

func (*TriggerAllResponse) String

func (x *TriggerAllResponse) String() string

type TriggerInfoResponse added in v0.5.0

type TriggerInfoResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerInfoResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use TriggerInfoResponse.ProtoReflect.Descriptor instead.

func (*TriggerInfoResponse) GetNames added in v0.5.0

func (x *TriggerInfoResponse) GetNames() []string

func (*TriggerInfoResponse) ProtoMessage added in v0.5.0

func (*TriggerInfoResponse) ProtoMessage()

func (*TriggerInfoResponse) ProtoReflect added in v0.5.0

func (x *TriggerInfoResponse) ProtoReflect() protoreflect.Message

func (*TriggerInfoResponse) Reset added in v0.5.0

func (x *TriggerInfoResponse) Reset()

func (*TriggerInfoResponse) String added in v0.5.0

func (x *TriggerInfoResponse) String() string

type UnimplementedAdminServer

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer should be embedded to have forward compatible implementations.

func (UnimplementedAdminServer) ListHosts

func (UnimplementedAdminServer) RemoveHost added in v0.5.9

func (UnimplementedAdminServer) TriggerAll

func (UnimplementedAdminServer) TriggerInfo added in v0.5.0

type UnimplementedRSCAServer

type UnimplementedRSCAServer struct {
}

UnimplementedRSCAServer should be embedded to have forward compatible implementations.

func (UnimplementedRSCAServer) Pipe

type UnsafeAdminServer added in v0.5.6

type UnsafeAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServer will result in compilation errors.

type UnsafeRSCAServer added in v0.5.6

type UnsafeRSCAServer interface {
	// contains filtered or unexported methods
}

UnsafeRSCAServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RSCAServer will result in compilation errors.

Jump to

Keyboard shortcuts

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