entity

type AllEntities struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

type AllEntityStatus struct {
	StreamKey string          `protobuf:"bytes,1,opt,name=StreamKey,proto3" json:"StreamKey,omitempty"`
	Status    []*EntityStatus `protobuf:"bytes,2,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type Entity struct {
	ID          string               `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name        string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string               `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	UserID      string               `protobuf:"bytes,4,opt,name=userID,proto3" json:"userID,omitempty"`
	CreatedAt   string               `protobuf:"bytes,5,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Scheme      string               `protobuf:"bytes,6,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Active      bool                 `protobuf:"varint,7,opt,name=active,proto3" json:"active,omitempty"`
	Public      *EntityPublicOptions `protobuf:"bytes,8,opt,name=public,proto3" json:"public,omitempty"`
	Options     *structpb.Struct     `protobuf:"bytes,9,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type EntityID struct {
	ID     string  `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Scheme *string `protobuf:"bytes,2,opt,name=scheme,proto3,oneof" json:"scheme,omitempty"`
	// contains filtered or unexported fields
}

type EntityPublicOptions struct {
	Threshold   *int32   `protobuf:"varint,1,opt,name=threshold,proto3,oneof" json:"threshold,omitempty"`
	TriggerList []string `protobuf:"bytes,2,rep,name=triggerList,proto3" json:"triggerList,omitempty"`
	Multiplier  *uint32  `protobuf:"varint,3,opt,name=multiplier,proto3,oneof" json:"multiplier,omitempty"`
	// contains filtered or unexported fields
}

type EntitySeries struct {
	ID     string           `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Series *structpb.Struct `protobuf:"bytes,2,opt,name=series,proto3" json:"series,omitempty"`
	// contains filtered or unexported fields
}

type EntityServiceClient interface {
	DeleteEntity(ctx context.Context, in *EntityID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NewEntity(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*EntityID, error)
	UpdateEntity(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetEntity(ctx context.Context, in *EntityID, opts ...grpc.CallOption) (*Entity, error)
	GetAllEntities(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllEntities, error)
	GetStatus(ctx context.Context, in *EntityID, opts ...grpc.CallOption) (*EntityStatus, error)
	GetAllStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllEntityStatus, error)
	GetSeries(ctx context.Context, in *EntityID, opts ...grpc.CallOption) (*EntitySeries, error)
	GetOfflineLog(ctx context.Context, in *OfflineLogRequest, opts ...grpc.CallOption) (*OfflineLogPage, error)
	GetStreamAllStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (EntityService_GetStreamAllStatusClient, error)
	StreamAck(ctx context.Context, in *StreamAckRequire, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type EntityServiceServer interface {
	DeleteEntity(context.Context, *EntityID) (*emptypb.Empty, error)
	NewEntity(context.Context, *Entity) (*EntityID, error)
	UpdateEntity(context.Context, *Entity) (*emptypb.Empty, error)
	GetEntity(context.Context, *EntityID) (*Entity, error)
	GetAllEntities(context.Context, *emptypb.Empty) (*AllEntities, error)
	GetStatus(context.Context, *EntityID) (*EntityStatus, error)
	GetAllStatus(context.Context, *emptypb.Empty) (*AllEntityStatus, error)
	GetSeries(context.Context, *EntityID) (*EntitySeries, error)
	GetOfflineLog(context.Context, *OfflineLogRequest) (*OfflineLogPage, error)
	GetStreamAllStatus(*emptypb.Empty, EntityService_GetStreamAllStatusServer) error
	StreamAck(context.Context, *StreamAckRequire) (*emptypb.Empty, error)
}

type EntityService_GetStreamAllStatusClient interface {
	Recv() (*AllEntityStatus, error)
	grpc.ClientStream
}

type EntityService_GetStreamAllStatusServer interface {
	Send(*AllEntityStatus) error
	grpc.ServerStream
}

type EntityStatus struct {
	ID             string           `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Live           bool             `protobuf:"varint,2,opt,name=live,proto3" json:"live,omitempty"`
	UpTime         string           `protobuf:"bytes,3,opt,name=up_time,json=upTime,proto3" json:"up_time,omitempty"`
	SentryTime     string           `protobuf:"bytes,4,opt,name=sentry_time,json=sentryTime,proto3" json:"sentry_time,omitempty"`
	ErrMessage     string           `protobuf:"bytes,5,opt,name=err_message,json=errMessage,proto3" json:"err_message,omitempty"`
	Fields         *structpb.Struct `protobuf:"bytes,6,opt,name=fields,proto3" json:"fields,omitempty"`
	LiveSeries     []bool           `protobuf:"varint,7,rep,packed,name=live_series,json=liveSeries,proto3" json:"live_series,omitempty"`
	ResponseTime   int64            `protobuf:"varint,8,opt,name=response_time,json=responseTime,proto3" json:"response_time,omitempty"`
	LivePercentage float64          `protobuf:"fixed64,9,opt,name=live_percentage,json=livePercentage,proto3" json:"live_percentage,omitempty"`
	// contains filtered or unexported fields
}

type OfflineLog struct {
	OfflineTime string       `protobuf:"bytes,1,opt,name=offlineTime,proto3" json:"offlineTime,omitempty"`
	Duration    string       `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	SentryLogs  []*SentryLog `protobuf:"bytes,3,rep,name=sentryLogs,proto3" json:"sentryLogs,omitempty"`
	// contains filtered or unexported fields
}

type OfflineLogPage struct {
	Length      int32         `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	OfflineLogs []*OfflineLog `protobuf:"bytes,2,rep,name=offlineLogs,proto3" json:"offlineLogs,omitempty"`
	// contains filtered or unexported fields
}

type OfflineLogRequest struct {
	EntityID   string             `protobuf:"bytes,1,opt,name=entityID,proto3" json:"entityID,omitempty"`
	Pagination *public.Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

type SentryLog struct {
	SentryName   string `protobuf:"bytes,1,opt,name=sentryName,proto3" json:"sentryName,omitempty"`
	SentryTime   string `protobuf:"bytes,2,opt,name=sentryTime,proto3" json:"sentryTime,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedEntityServiceServer struct {
}

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