pb

Documentation

Index

• Variables
• func RegisterProcjonServer(s *grpc.Server, srv ProcjonServer)
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (x *Empty) ProtoReflect() protoreflect.Message
  • func (x *Empty) Reset()
  • func (x *Empty) String() string
• type ProcjonClient
  • func NewProcjonClient(cc grpc.ClientConnInterface) ProcjonClient
• type ProcjonServer
• type Procjon_SendServiceStatusClient
• type Procjon_SendServiceStatusServer
• type Service
  • func (*Service) Descriptor() ([]byte, []int)
  • func (x *Service) GetServiceIdentifier() string
  • func (x *Service) GetStatuses() map[int32]string
  • func (x *Service) GetTimeout() int32
  • func (*Service) ProtoMessage()
  • func (x *Service) ProtoReflect() protoreflect.Message
  • func (x *Service) Reset()
  • func (x *Service) String() string
• type ServiceStatus
  • func (*ServiceStatus) Descriptor() ([]byte, []int)
  • func (x *ServiceStatus) GetServiceIdentifier() string
  • func (x *ServiceStatus) GetStatusCode() int32
  • func (*ServiceStatus) ProtoMessage()
  • func (x *ServiceStatus) ProtoReflect() protoreflect.Message
  • func (x *ServiceStatus) Reset()
  • func (x *ServiceStatus) String() string
• type UnimplementedProcjonServer
  • func (*UnimplementedProcjonServer) RegisterService(context.Context, *Service) (*Empty, error)
  • func (*UnimplementedProcjonServer) SendServiceStatus(Procjon_SendServiceStatusServer) error

Variables

var File_pb_procjon_proto protoreflect.FileDescriptor

Functions

func RegisterProcjonServer

func RegisterProcjonServer(s *grpc.Server, srv ProcjonServer)

Types

type Empty

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

func (*Empty) Descriptor

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 ProcjonClient

type ProcjonClient interface {
	RegisterService(ctx context.Context, in *Service, opts ...grpc.CallOption) (*Empty, error)
	SendServiceStatus(ctx context.Context, opts ...grpc.CallOption) (Procjon_SendServiceStatusClient, error)
}

ProcjonClient is the client API for Procjon 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 NewProcjonClient

func NewProcjonClient(cc grpc.ClientConnInterface) ProcjonClient

type ProcjonServer

type ProcjonServer interface {
	RegisterService(context.Context, *Service) (*Empty, error)
	SendServiceStatus(Procjon_SendServiceStatusServer) error
	// contains filtered or unexported methods
}

ProcjonServer is the server API for Procjon service. All implementations must embed UnimplementedProcjonServer for forward compatibility

type Procjon_SendServiceStatusClient

type Procjon_SendServiceStatusClient interface {
	Send(*ServiceStatus) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Procjon_SendServiceStatusServer

type Procjon_SendServiceStatusServer interface {
	SendAndClose(*Empty) error
	Recv() (*ServiceStatus, error)
	grpc.ServerStream
}

type Service

type Service struct {
	ServiceIdentifier string           `protobuf:"bytes,1,opt,name=serviceIdentifier,proto3" json:"serviceIdentifier,omitempty"`
	Statuses          map[int32]string `` /* 158-byte string literal not displayed */
	Timeout           int32            `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetServiceIdentifier

func (x *Service) GetServiceIdentifier() string

func (*Service) GetStatuses

func (x *Service) GetStatuses() map[int32]string

func (*Service) GetTimeout

func (x *Service) GetTimeout() int32

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type ServiceStatus

type ServiceStatus struct {
	ServiceIdentifier string `protobuf:"bytes,1,opt,name=serviceIdentifier,proto3" json:"serviceIdentifier,omitempty"`
	StatusCode        int32  `protobuf:"varint,2,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceStatus) Descriptor

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

Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.

func (*ServiceStatus) GetServiceIdentifier

func (x *ServiceStatus) GetServiceIdentifier() string

func (*ServiceStatus) GetStatusCode

func (x *ServiceStatus) GetStatusCode() int32

func (*ServiceStatus) ProtoMessage

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) ProtoReflect

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

func (*ServiceStatus) Reset

func (x *ServiceStatus) Reset()

func (*ServiceStatus) String

func (x *ServiceStatus) String() string

type UnimplementedProcjonServer

type UnimplementedProcjonServer struct {
}

UnimplementedProcjonServer must be embedded to have forward compatible implementations.

func (*UnimplementedProcjonServer) RegisterService

func (*UnimplementedProcjonServer) RegisterService(context.Context, *Service) (*Empty, error)

func (*UnimplementedProcjonServer) SendServiceStatus

func (*UnimplementedProcjonServer) SendServiceStatus(Procjon_SendServiceStatusServer) error