centrum

package

Go to main page

Versions in this module

v0

v0.9.0

Apr 10, 2024

v0.8.21

Apr 9, 2024

Changes in this version

type LatestState

+ OwnUnitId *uint64

+ func (x *LatestState) GetOwnUnitId() uint64

type Params

+ AppConfig appconfig.IConfig

v0.8.20

Feb 28, 2024

Changes in this version

+ const CentrumService_GetDispatch_FullMethodName

type CentrumServiceClient

+ GetDispatch func(ctx context.Context, in *GetDispatchRequest, opts ...grpc.CallOption) (*GetDispatchResponse, error)

type CentrumServiceServer

+ GetDispatch func(context.Context, *GetDispatchRequest) (*GetDispatchResponse, error)

+ type GetDispatchRequest struct

+ Id uint64

+ func (*GetDispatchRequest) Descriptor() ([]byte, []int)

+ func (*GetDispatchRequest) ProtoMessage()

+ func (m *GetDispatchRequest) Validate() error

+ func (m *GetDispatchRequest) ValidateAll() error

+ func (x *GetDispatchRequest) GetId() uint64

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

+ func (x *GetDispatchRequest) Reset()

+ func (x *GetDispatchRequest) String() string

+ type GetDispatchRequestMultiError []error

+ func (m GetDispatchRequestMultiError) AllErrors() []error

+ func (m GetDispatchRequestMultiError) Error() string

+ type GetDispatchRequestValidationError struct

+ func (e GetDispatchRequestValidationError) Cause() error

+ func (e GetDispatchRequestValidationError) Error() string

+ func (e GetDispatchRequestValidationError) ErrorName() string

+ func (e GetDispatchRequestValidationError) Field() string

+ func (e GetDispatchRequestValidationError) Key() bool

+ func (e GetDispatchRequestValidationError) Reason() string

+ type GetDispatchResponse struct

+ Dispatch *centrum.Dispatch

+ func (*GetDispatchResponse) Descriptor() ([]byte, []int)

+ func (*GetDispatchResponse) ProtoMessage()

+ func (m *GetDispatchResponse) Validate() error

+ func (m *GetDispatchResponse) ValidateAll() error

+ func (x *GetDispatchResponse) GetDispatch() *centrum.Dispatch

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

+ func (x *GetDispatchResponse) Reset()

+ func (x *GetDispatchResponse) String() string

+ type GetDispatchResponseMultiError []error

+ func (m GetDispatchResponseMultiError) AllErrors() []error

+ func (m GetDispatchResponseMultiError) Error() string

+ type GetDispatchResponseValidationError struct

+ func (e GetDispatchResponseValidationError) Cause() error

+ func (e GetDispatchResponseValidationError) Error() string

+ func (e GetDispatchResponseValidationError) ErrorName() string

+ func (e GetDispatchResponseValidationError) Field() string

+ func (e GetDispatchResponseValidationError) Key() bool

+ func (e GetDispatchResponseValidationError) Reason() string

type Server

+ func (s *Server) GetDispatch(ctx context.Context, req *GetDispatchRequest) (*GetDispatchResponse, error)

type UnimplementedCentrumServiceServer

+ func (UnimplementedCentrumServiceServer) GetDispatch(context.Context, *GetDispatchRequest) (*GetDispatchResponse, error)

v0.8.19

Jan 27, 2024

Changes in this version

type ListDispatchesRequest

+ Ids []uint64

+ Postal *string

+ func (x *ListDispatchesRequest) GetIds() []uint64

+ func (x *ListDispatchesRequest) GetPostal() string

v0.8.18

Jan 13, 2024

v0.8.17

Jan 5, 2024

v0.8.16

Jan 5, 2024

Changes in this version

type LatestState

+ ServerTime *timestamp.Timestamp

+ func (x *LatestState) GetServerTime() *timestamp.Timestamp

v0.8.14

Nov 26, 2023

v0.8.13

Nov 24, 2023

Changes in this version

type Params

+ JS nats.JetStreamContext

v0.8.12

Nov 16, 2023

Changes in this version

type Server

+ func (s *Server) RegisterSubscriptions(ctx context.Context) error

v0.8.11

Nov 15, 2023

Changes in this version

+ type GetSettingsResponse struct

+ Settings *dispatch.Settings

+ func (*GetSettingsResponse) Descriptor() ([]byte, []int)

+ func (*GetSettingsResponse) ProtoMessage()

+ func (m *GetSettingsResponse) Validate() error

+ func (m *GetSettingsResponse) ValidateAll() error

+ func (x *GetSettingsResponse) GetSettings() *dispatch.Settings

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

+ func (x *GetSettingsResponse) Reset()

+ func (x *GetSettingsResponse) String() string

+ type GetSettingsResponseMultiError []error

+ func (m GetSettingsResponseMultiError) AllErrors() []error

+ func (m GetSettingsResponseMultiError) Error() string

+ type GetSettingsResponseValidationError struct

+ func (e GetSettingsResponseValidationError) Cause() error

+ func (e GetSettingsResponseValidationError) Error() string

+ func (e GetSettingsResponseValidationError) ErrorName() string

+ func (e GetSettingsResponseValidationError) Field() string

+ func (e GetSettingsResponseValidationError) Key() bool

+ func (e GetSettingsResponseValidationError) Reason() string

type StreamResponse

+ func (x *StreamResponse) GetUnitCreated() *dispatch.Unit

+ type StreamResponse_UnitCreated struct

+ UnitCreated *dispatch.Unit

+ type UpdateSettingsRequest struct

+ Settings *dispatch.Settings

+ func (*UpdateSettingsRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSettingsRequest) ProtoMessage()

+ func (m *UpdateSettingsRequest) Validate() error

+ func (m *UpdateSettingsRequest) ValidateAll() error

+ func (x *UpdateSettingsRequest) GetSettings() *dispatch.Settings

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

+ func (x *UpdateSettingsRequest) Reset()

+ func (x *UpdateSettingsRequest) String() string

+ type UpdateSettingsRequestMultiError []error

+ func (m UpdateSettingsRequestMultiError) AllErrors() []error

+ func (m UpdateSettingsRequestMultiError) Error() string

+ type UpdateSettingsRequestValidationError struct

+ func (e UpdateSettingsRequestValidationError) Cause() error

+ func (e UpdateSettingsRequestValidationError) Error() string

+ func (e UpdateSettingsRequestValidationError) ErrorName() string

+ func (e UpdateSettingsRequestValidationError) Field() string

+ func (e UpdateSettingsRequestValidationError) Key() bool

+ func (e UpdateSettingsRequestValidationError) Reason() string

+ type UpdateSettingsResponse struct

+ Settings *dispatch.Settings

+ func (*UpdateSettingsResponse) Descriptor() ([]byte, []int)

+ func (*UpdateSettingsResponse) ProtoMessage()

+ func (m *UpdateSettingsResponse) Validate() error

+ func (m *UpdateSettingsResponse) ValidateAll() error

+ func (x *UpdateSettingsResponse) GetSettings() *dispatch.Settings

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

+ func (x *UpdateSettingsResponse) Reset()

+ func (x *UpdateSettingsResponse) String() string

+ type UpdateSettingsResponseMultiError []error

+ func (m UpdateSettingsResponseMultiError) AllErrors() []error

+ func (m UpdateSettingsResponseMultiError) Error() string

+ type UpdateSettingsResponseValidationError struct

+ func (e UpdateSettingsResponseValidationError) Cause() error

+ func (e UpdateSettingsResponseValidationError) Error() string

+ func (e UpdateSettingsResponseValidationError) ErrorName() string

+ func (e UpdateSettingsResponseValidationError) Field() string

+ func (e UpdateSettingsResponseValidationError) Key() bool

+ func (e UpdateSettingsResponseValidationError) Reason() string

v0.8.10

Oct 31, 2023

Changes in this version

type ListDispatchesRequest

+ Pagination *database.PaginationRequest

+ func (x *ListDispatchesRequest) GetPagination() *database.PaginationRequest

type ListDispatchesResponse

+ Pagination *database.PaginationResponse

+ func (x *ListDispatchesResponse) GetPagination() *database.PaginationResponse

v0.8.9

Oct 25, 2023

v0.8.8

Oct 16, 2023

Changes in this version

type AssignDispatchRequest

+ Forced *bool

+ func (x *AssignDispatchRequest) GetForced() bool

type Params

+ BotManager *bot.Manager

+ Manager *manager.Manager

v0.8.7

Oct 12, 2023

v0.8.6

Oct 6, 2023

Changes in this version

+ var ErrDispatchAlreadyCompleted = status.Error(codes.InvalidArgument, ...)

type Params

+ State *state.State

v0.8.5

Sep 28, 2023

Changes in this version

type Bot

+ func (b *Bot) Start(job string) error

+ func (b *Bot) Stop(job string) error

v0.8.4

Sep 24, 2023

v0.8.3

Sep 22, 2023

Changes in this version

+ var TakeDispatchResp_name = map[int32]string

+ var TakeDispatchResp_value = map[string]int32

+ type TakeDispatchResp int32

+ const TakeDispatchResp_TAKE_DISPATCH_RESP_ACCEPTED

+ const TakeDispatchResp_TAKE_DISPATCH_RESP_DECLINED

+ const TakeDispatchResp_TAKE_DISPATCH_RESP_TIMEOUT

+ const TakeDispatchResp_TAKE_DISPATCH_RESP_UNSPECIFIED

+ func (TakeDispatchResp) Descriptor() protoreflect.EnumDescriptor

+ func (TakeDispatchResp) EnumDescriptor() ([]byte, []int)

+ func (TakeDispatchResp) Type() protoreflect.EnumType

+ func (x TakeDispatchResp) Enum() *TakeDispatchResp

+ func (x TakeDispatchResp) Number() protoreflect.EnumNumber

+ func (x TakeDispatchResp) String() string

v0.8.2

Sep 20, 2023

Changes in this version

+ type Bot struct

+ type BotManager struct

+ func NewBotManager() *BotManager

v0.8.1

Sep 13, 2023

Changes in this version

+ const CentrumServiceDeleteDispatchPerm

+ const CentrumService_DeleteDispatch_FullMethodName

+ const DispatchExpirationTime

+ var ErrModeForbidsAction = status.Error(codes.InvalidArgument, "Dispatch center forbides this interaction")

+ var ErrNotOnDuty = status.Error(codes.InvalidArgument, "errors.CentrumService.ErrNotOnDuty")

type CentrumServiceClient

+ DeleteDispatch func(ctx context.Context, in *DeleteDispatchRequest, opts ...grpc.CallOption) (*DeleteDispatchResponse, error)

type CentrumServiceServer

+ DeleteDispatch func(context.Context, *DeleteDispatchRequest) (*DeleteDispatchResponse, error)

+ type DeleteDispatchRequest struct

+ Id uint64

+ func (*DeleteDispatchRequest) Descriptor() ([]byte, []int)

+ func (*DeleteDispatchRequest) ProtoMessage()

+ func (m *DeleteDispatchRequest) Validate() error

+ func (m *DeleteDispatchRequest) ValidateAll() error

+ func (x *DeleteDispatchRequest) GetId() uint64

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

+ func (x *DeleteDispatchRequest) Reset()

+ func (x *DeleteDispatchRequest) String() string

+ type DeleteDispatchRequestMultiError []error

+ func (m DeleteDispatchRequestMultiError) AllErrors() []error

+ func (m DeleteDispatchRequestMultiError) Error() string

+ type DeleteDispatchRequestValidationError struct

+ func (e DeleteDispatchRequestValidationError) Cause() error

+ func (e DeleteDispatchRequestValidationError) Error() string

+ func (e DeleteDispatchRequestValidationError) ErrorName() string

+ func (e DeleteDispatchRequestValidationError) Field() string

+ func (e DeleteDispatchRequestValidationError) Key() bool

+ func (e DeleteDispatchRequestValidationError) Reason() string

+ type DeleteDispatchResponse struct

+ func (*DeleteDispatchResponse) Descriptor() ([]byte, []int)

+ func (*DeleteDispatchResponse) ProtoMessage()

+ func (m *DeleteDispatchResponse) Validate() error

+ func (m *DeleteDispatchResponse) ValidateAll() error

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

+ func (x *DeleteDispatchResponse) Reset()

+ func (x *DeleteDispatchResponse) String() string

+ type DeleteDispatchResponseMultiError []error

+ func (m DeleteDispatchResponseMultiError) AllErrors() []error

+ func (m DeleteDispatchResponseMultiError) Error() string

+ type DeleteDispatchResponseValidationError struct

+ func (e DeleteDispatchResponseValidationError) Cause() error

+ func (e DeleteDispatchResponseValidationError) Error() string

+ func (e DeleteDispatchResponseValidationError) ErrorName() string

+ func (e DeleteDispatchResponseValidationError) Field() string

+ func (e DeleteDispatchResponseValidationError) Key() bool

+ func (e DeleteDispatchResponseValidationError) Reason() string

type Params

+ Postals *postals.Postals

type Server

+ func (s *Server) DeleteDispatch(ctx context.Context, req *DeleteDispatchRequest) (*DeleteDispatchResponse, error)

type StreamResponse

+ func (x *StreamResponse) GetPing() string

+ type StreamResponse_Ping struct

+ Ping string

type TakeDispatchRequest

+ func (m *TakeDispatchRequest) Sanitize() error

type UnimplementedCentrumServiceServer

+ func (UnimplementedCentrumServiceServer) DeleteDispatch(context.Context, *DeleteDispatchRequest) (*DeleteDispatchResponse, error)

type UpdateDispatchStatusRequest

+ func (m *UpdateDispatchStatusRequest) Sanitize() error

type UpdateUnitStatusRequest

+ func (m *UpdateUnitStatusRequest) Sanitize() error

v0.8.0

Aug 22, 2023

Changes in this version

+ const BaseSubject

+ const CentrumServiceCreateOrUpdateUnitPerm

+ const CentrumServiceDeleteUnitPerm

+ const CentrumServiceTakeControlPerm

+ const CentrumServiceTakeDispatchPerm

+ const CentrumServiceUpdateDispatchPerm

+ const CentrumServiceUpdateSettingsPerm

+ const CentrumService_AssignDispatch_FullMethodName

+ const CentrumService_AssignUnit_FullMethodName

+ const CentrumService_CreateDispatch_FullMethodName

+ const CentrumService_CreateOrUpdateUnit_FullMethodName

+ const CentrumService_DeleteUnit_FullMethodName

+ const CentrumService_GetSettings_FullMethodName

+ const CentrumService_JoinUnit_FullMethodName

+ const CentrumService_ListDispatchActivity_FullMethodName

+ const CentrumService_ListDispatches_FullMethodName

+ const CentrumService_ListUnitActivity_FullMethodName

+ const CentrumService_ListUnits_FullMethodName

+ const CentrumService_Stream_FullMethodName

+ const CentrumService_TakeControl_FullMethodName

+ const CentrumService_TakeDispatch_FullMethodName

+ const CentrumService_UpdateDispatchStatus_FullMethodName

+ const CentrumService_UpdateDispatch_FullMethodName

+ const CentrumService_UpdateSettings_FullMethodName

+ const CentrumService_UpdateUnitStatus_FullMethodName

+ const TopicDispatch

+ const TopicGeneral

+ const TopicUnit

+ const TypeDispatchCreated

+ const TypeDispatchDeleted

+ const TypeDispatchStatus

+ const TypeDispatchUpdated

+ const TypeGeneralDisponents

+ const TypeGeneralSettings

+ const TypeUnitDeleted

+ const TypeUnitStatus

+ const TypeUnitUpdated

+ const TypeUnitUserAssigned

+ var ErrAlreadyInUnit = status.Error(codes.InvalidArgument, "errors.CentrumService.ErrAlreadyInUnit")

+ var ErrFailedQuery = status.Error(codes.Internal, "errors.CentrumService.ErrFailedQuery")

+ var ErrNotPartOfDispatch = status.Error(codes.InvalidArgument, "errors.CentrumService.ErrNotPartOfDispatch")

+ var TAKE_DISPATCH_RESP_name = map[int32]string

+ var TAKE_DISPATCH_RESP_value = map[string]int32

+ type AssignDispatchRequest struct

+ DispatchId uint64

+ ToAdd []uint64

+ ToRemove []uint64

+ func (*AssignDispatchRequest) Descriptor() ([]byte, []int)

+ func (*AssignDispatchRequest) ProtoMessage()

+ func (m *AssignDispatchRequest) Validate() error

+ func (m *AssignDispatchRequest) ValidateAll() error

+ func (x *AssignDispatchRequest) GetDispatchId() uint64

+ func (x *AssignDispatchRequest) GetToAdd() []uint64

+ func (x *AssignDispatchRequest) GetToRemove() []uint64

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

+ func (x *AssignDispatchRequest) Reset()

+ func (x *AssignDispatchRequest) String() string

+ type AssignDispatchRequestMultiError []error

+ func (m AssignDispatchRequestMultiError) AllErrors() []error

+ func (m AssignDispatchRequestMultiError) Error() string

+ type AssignDispatchRequestValidationError struct

+ func (e AssignDispatchRequestValidationError) Cause() error

+ func (e AssignDispatchRequestValidationError) Error() string

+ func (e AssignDispatchRequestValidationError) ErrorName() string

+ func (e AssignDispatchRequestValidationError) Field() string

+ func (e AssignDispatchRequestValidationError) Key() bool

+ func (e AssignDispatchRequestValidationError) Reason() string

+ type AssignDispatchResponse struct

+ func (*AssignDispatchResponse) Descriptor() ([]byte, []int)

+ func (*AssignDispatchResponse) ProtoMessage()

+ func (m *AssignDispatchResponse) Validate() error

+ func (m *AssignDispatchResponse) ValidateAll() error

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

+ func (x *AssignDispatchResponse) Reset()

+ func (x *AssignDispatchResponse) String() string

+ type AssignDispatchResponseMultiError []error

+ func (m AssignDispatchResponseMultiError) AllErrors() []error

+ func (m AssignDispatchResponseMultiError) Error() string

+ type AssignDispatchResponseValidationError struct

+ func (e AssignDispatchResponseValidationError) Cause() error

+ func (e AssignDispatchResponseValidationError) Error() string

+ func (e AssignDispatchResponseValidationError) ErrorName() string

+ func (e AssignDispatchResponseValidationError) Field() string

+ func (e AssignDispatchResponseValidationError) Key() bool

+ func (e AssignDispatchResponseValidationError) Reason() string

type CentrumServiceClient

+ AssignDispatch func(ctx context.Context, in *AssignDispatchRequest, opts ...grpc.CallOption) (*AssignDispatchResponse, error)

+ AssignUnit func(ctx context.Context, in *AssignUnitRequest, opts ...grpc.CallOption) (*AssignUnitResponse, error)

+ CreateOrUpdateUnit func(ctx context.Context, in *CreateOrUpdateUnitRequest, opts ...grpc.CallOption) (*CreateOrUpdateUnitResponse, error)

+ DeleteUnit func(ctx context.Context, in *DeleteUnitRequest, opts ...grpc.CallOption) (*DeleteUnitResponse, error)

+ GetSettings func(ctx context.Context, in *GetSettingsRequest, opts ...grpc.CallOption) (*dispatch.Settings, error)

+ JoinUnit func(ctx context.Context, in *JoinUnitRequest, opts ...grpc.CallOption) (*JoinUnitResponse, error)

+ ListDispatchActivity func(ctx context.Context, in *ListDispatchActivityRequest, opts ...grpc.CallOption) (*ListDispatchActivityResponse, error)

+ ListDispatches func(ctx context.Context, in *ListDispatchesRequest, opts ...grpc.CallOption) (*ListDispatchesResponse, error)

+ ListUnitActivity func(ctx context.Context, in *ListUnitActivityRequest, opts ...grpc.CallOption) (*ListUnitActivityResponse, error)

+ ListUnits func(ctx context.Context, in *ListUnitsRequest, opts ...grpc.CallOption) (*ListUnitsResponse, error)

+ TakeControl func(ctx context.Context, in *TakeControlRequest, opts ...grpc.CallOption) (*TakeControlResponse, error)

+ TakeDispatch func(ctx context.Context, in *TakeDispatchRequest, opts ...grpc.CallOption) (*TakeDispatchResponse, error)

+ UpdateDispatch func(ctx context.Context, in *UpdateDispatchRequest, opts ...grpc.CallOption) (*UpdateDispatchResponse, error)

+ UpdateDispatchStatus func(ctx context.Context, in *UpdateDispatchStatusRequest, opts ...grpc.CallOption) (*UpdateDispatchStatusResponse, error)

+ UpdateSettings func(ctx context.Context, in *dispatch.Settings, opts ...grpc.CallOption) (*dispatch.Settings, error)

+ UpdateUnitStatus func(ctx context.Context, in *UpdateUnitStatusRequest, opts ...grpc.CallOption) (*UpdateUnitStatusResponse, error)

type CentrumServiceServer

+ AssignDispatch func(context.Context, *AssignDispatchRequest) (*AssignDispatchResponse, error)

+ AssignUnit func(context.Context, *AssignUnitRequest) (*AssignUnitResponse, error)

+ CreateOrUpdateUnit func(context.Context, *CreateOrUpdateUnitRequest) (*CreateOrUpdateUnitResponse, error)

+ DeleteUnit func(context.Context, *DeleteUnitRequest) (*DeleteUnitResponse, error)

+ GetSettings func(context.Context, *GetSettingsRequest) (*dispatch.Settings, error)

+ JoinUnit func(context.Context, *JoinUnitRequest) (*JoinUnitResponse, error)

+ ListDispatchActivity func(context.Context, *ListDispatchActivityRequest) (*ListDispatchActivityResponse, error)

+ ListDispatches func(context.Context, *ListDispatchesRequest) (*ListDispatchesResponse, error)

+ ListUnitActivity func(context.Context, *ListUnitActivityRequest) (*ListUnitActivityResponse, error)

+ ListUnits func(context.Context, *ListUnitsRequest) (*ListUnitsResponse, error)

+ TakeControl func(context.Context, *TakeControlRequest) (*TakeControlResponse, error)

+ TakeDispatch func(context.Context, *TakeDispatchRequest) (*TakeDispatchResponse, error)

+ UpdateDispatch func(context.Context, *UpdateDispatchRequest) (*UpdateDispatchResponse, error)

+ UpdateDispatchStatus func(context.Context, *UpdateDispatchStatusRequest) (*UpdateDispatchStatusResponse, error)

+ UpdateSettings func(context.Context, *dispatch.Settings) (*dispatch.Settings, error)

+ UpdateUnitStatus func(context.Context, *UpdateUnitStatusRequest) (*UpdateUnitStatusResponse, error)

type CreateDispatchRequest

+ Dispatch *dispatch.Dispatch

+ func (x *CreateDispatchRequest) GetDispatch() *dispatch.Dispatch

type CreateDispatchResponse

+ Dispatch *dispatch.Dispatch

+ func (x *CreateDispatchResponse) GetDispatch() *dispatch.Dispatch

+ type CreateOrUpdateUnitRequest struct

+ Unit *dispatch.Unit

+ func (*CreateOrUpdateUnitRequest) Descriptor() ([]byte, []int)

+ func (*CreateOrUpdateUnitRequest) ProtoMessage()

+ func (m *CreateOrUpdateUnitRequest) Validate() error

+ func (m *CreateOrUpdateUnitRequest) ValidateAll() error

+ func (x *CreateOrUpdateUnitRequest) GetUnit() *dispatch.Unit

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

+ func (x *CreateOrUpdateUnitRequest) Reset()

+ func (x *CreateOrUpdateUnitRequest) String() string

+ type CreateOrUpdateUnitRequestMultiError []error

+ func (m CreateOrUpdateUnitRequestMultiError) AllErrors() []error

+ func (m CreateOrUpdateUnitRequestMultiError) Error() string

+ type CreateOrUpdateUnitRequestValidationError struct

+ func (e CreateOrUpdateUnitRequestValidationError) Cause() error

+ func (e CreateOrUpdateUnitRequestValidationError) Error() string

+ func (e CreateOrUpdateUnitRequestValidationError) ErrorName() string

+ func (e CreateOrUpdateUnitRequestValidationError) Field() string

+ func (e CreateOrUpdateUnitRequestValidationError) Key() bool

+ func (e CreateOrUpdateUnitRequestValidationError) Reason() string

+ type CreateOrUpdateUnitResponse struct

+ Unit *dispatch.Unit

+ func (*CreateOrUpdateUnitResponse) Descriptor() ([]byte, []int)

+ func (*CreateOrUpdateUnitResponse) ProtoMessage()

+ func (m *CreateOrUpdateUnitResponse) Validate() error

+ func (m *CreateOrUpdateUnitResponse) ValidateAll() error

+ func (x *CreateOrUpdateUnitResponse) GetUnit() *dispatch.Unit

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

+ func (x *CreateOrUpdateUnitResponse) Reset()

+ func (x *CreateOrUpdateUnitResponse) String() string

+ type CreateOrUpdateUnitResponseMultiError []error

+ func (m CreateOrUpdateUnitResponseMultiError) AllErrors() []error

+ func (m CreateOrUpdateUnitResponseMultiError) Error() string

+ type CreateOrUpdateUnitResponseValidationError struct

+ func (e CreateOrUpdateUnitResponseValidationError) Cause() error

+ func (e CreateOrUpdateUnitResponseValidationError) Error() string

+ func (e CreateOrUpdateUnitResponseValidationError) ErrorName() string

+ func (e CreateOrUpdateUnitResponseValidationError) Field() string

+ func (e CreateOrUpdateUnitResponseValidationError) Key() bool

+ func (e CreateOrUpdateUnitResponseValidationError) Reason() string

+ type DisponentsChange struct

+ Disponents []*users.UserShort

+ Job string

+ func (*DisponentsChange) Descriptor() ([]byte, []int)

+ func (*DisponentsChange) ProtoMessage()

+ func (m *DisponentsChange) Validate() error

+ func (m *DisponentsChange) ValidateAll() error

+ func (x *DisponentsChange) GetDisponents() []*users.UserShort

+ func (x *DisponentsChange) GetJob() string

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

+ func (x *DisponentsChange) Reset()

+ func (x *DisponentsChange) String() string

+ type DisponentsChangeMultiError []error

+ func (m DisponentsChangeMultiError) AllErrors() []error

+ func (m DisponentsChangeMultiError) Error() string

+ type DisponentsChangeValidationError struct

+ func (e DisponentsChangeValidationError) Cause() error

+ func (e DisponentsChangeValidationError) Error() string

+ func (e DisponentsChangeValidationError) ErrorName() string

+ func (e DisponentsChangeValidationError) Field() string

+ func (e DisponentsChangeValidationError) Key() bool

+ func (e DisponentsChangeValidationError) Reason() string

+ type GetSettingsRequest struct

+ func (*GetSettingsRequest) Descriptor() ([]byte, []int)

+ func (*GetSettingsRequest) ProtoMessage()

+ func (m *GetSettingsRequest) Validate() error

+ func (m *GetSettingsRequest) ValidateAll() error

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

+ func (x *GetSettingsRequest) Reset()

+ func (x *GetSettingsRequest) String() string

+ type GetSettingsRequestMultiError []error

+ func (m GetSettingsRequestMultiError) AllErrors() []error

+ func (m GetSettingsRequestMultiError) Error() string

+ type GetSettingsRequestValidationError struct

+ func (e GetSettingsRequestValidationError) Cause() error

+ func (e GetSettingsRequestValidationError) Error() string

+ func (e GetSettingsRequestValidationError) ErrorName() string

+ func (e GetSettingsRequestValidationError) Field() string

+ func (e GetSettingsRequestValidationError) Key() bool

+ func (e GetSettingsRequestValidationError) Reason() string

+ type JoinUnitRequest struct

+ Leave *bool

+ UnitId uint64

+ func (*JoinUnitRequest) Descriptor() ([]byte, []int)

+ func (*JoinUnitRequest) ProtoMessage()

+ func (m *JoinUnitRequest) Validate() error

+ func (m *JoinUnitRequest) ValidateAll() error

+ func (x *JoinUnitRequest) GetLeave() bool

+ func (x *JoinUnitRequest) GetUnitId() uint64

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

+ func (x *JoinUnitRequest) Reset()

+ func (x *JoinUnitRequest) String() string

+ type JoinUnitRequestMultiError []error

+ func (m JoinUnitRequestMultiError) AllErrors() []error

+ func (m JoinUnitRequestMultiError) Error() string

+ type JoinUnitRequestValidationError struct

+ func (e JoinUnitRequestValidationError) Cause() error

+ func (e JoinUnitRequestValidationError) Error() string

+ func (e JoinUnitRequestValidationError) ErrorName() string

+ func (e JoinUnitRequestValidationError) Field() string

+ func (e JoinUnitRequestValidationError) Key() bool

+ func (e JoinUnitRequestValidationError) Reason() string

+ type JoinUnitResponse struct

+ Unit *dispatch.Unit

+ func (*JoinUnitResponse) Descriptor() ([]byte, []int)

+ func (*JoinUnitResponse) ProtoMessage()

+ func (m *JoinUnitResponse) Validate() error

+ func (m *JoinUnitResponse) ValidateAll() error

+ func (x *JoinUnitResponse) GetUnit() *dispatch.Unit

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

+ func (x *JoinUnitResponse) Reset()

+ func (x *JoinUnitResponse) String() string

+ type JoinUnitResponseMultiError []error

+ func (m JoinUnitResponseMultiError) AllErrors() []error

+ func (m JoinUnitResponseMultiError) Error() string

+ type JoinUnitResponseValidationError struct

+ func (e JoinUnitResponseValidationError) Cause() error

+ func (e JoinUnitResponseValidationError) Error() string

+ func (e JoinUnitResponseValidationError) ErrorName() string

+ func (e JoinUnitResponseValidationError) Field() string

+ func (e JoinUnitResponseValidationError) Key() bool

+ func (e JoinUnitResponseValidationError) Reason() string

+ type LatestState struct

+ Dispatches []*dispatch.Dispatch

+ Disponents []*users.UserShort

+ IsDisponent bool

+ OwnUnit *dispatch.Unit

+ Settings *dispatch.Settings

+ Units []*dispatch.Unit

+ func (*LatestState) Descriptor() ([]byte, []int)

+ func (*LatestState) ProtoMessage()

+ func (m *LatestState) Validate() error

+ func (m *LatestState) ValidateAll() error

+ func (x *LatestState) GetDispatches() []*dispatch.Dispatch

+ func (x *LatestState) GetDisponents() []*users.UserShort

+ func (x *LatestState) GetIsDisponent() bool

+ func (x *LatestState) GetOwnUnit() *dispatch.Unit

+ func (x *LatestState) GetSettings() *dispatch.Settings

+ func (x *LatestState) GetUnits() []*dispatch.Unit

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

+ func (x *LatestState) Reset()

+ func (x *LatestState) String() string

+ type LatestStateMultiError []error

+ func (m LatestStateMultiError) AllErrors() []error

+ func (m LatestStateMultiError) Error() string

+ type LatestStateValidationError struct

+ func (e LatestStateValidationError) Cause() error

+ func (e LatestStateValidationError) Error() string

+ func (e LatestStateValidationError) ErrorName() string

+ func (e LatestStateValidationError) Field() string

+ func (e LatestStateValidationError) Key() bool

+ func (e LatestStateValidationError) Reason() string

+ type ListDispatchActivityRequest struct

+ Id uint64

+ Pagination *database.PaginationRequest

+ func (*ListDispatchActivityRequest) Descriptor() ([]byte, []int)

+ func (*ListDispatchActivityRequest) ProtoMessage()

+ func (m *ListDispatchActivityRequest) Validate() error

+ func (m *ListDispatchActivityRequest) ValidateAll() error

+ func (x *ListDispatchActivityRequest) GetId() uint64

+ func (x *ListDispatchActivityRequest) GetPagination() *database.PaginationRequest

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

+ func (x *ListDispatchActivityRequest) Reset()

+ func (x *ListDispatchActivityRequest) String() string

+ type ListDispatchActivityRequestMultiError []error

+ func (m ListDispatchActivityRequestMultiError) AllErrors() []error

+ func (m ListDispatchActivityRequestMultiError) Error() string

+ type ListDispatchActivityRequestValidationError struct

+ func (e ListDispatchActivityRequestValidationError) Cause() error

+ func (e ListDispatchActivityRequestValidationError) Error() string

+ func (e ListDispatchActivityRequestValidationError) ErrorName() string

+ func (e ListDispatchActivityRequestValidationError) Field() string

+ func (e ListDispatchActivityRequestValidationError) Key() bool

+ func (e ListDispatchActivityRequestValidationError) Reason() string

+ type ListDispatchActivityResponse struct

+ Activity []*dispatch.DispatchStatus

+ Pagination *database.PaginationResponse

+ func (*ListDispatchActivityResponse) Descriptor() ([]byte, []int)

+ func (*ListDispatchActivityResponse) ProtoMessage()

+ func (m *ListDispatchActivityResponse) Validate() error

+ func (m *ListDispatchActivityResponse) ValidateAll() error

+ func (x *ListDispatchActivityResponse) GetActivity() []*dispatch.DispatchStatus

+ func (x *ListDispatchActivityResponse) GetPagination() *database.PaginationResponse

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

+ func (x *ListDispatchActivityResponse) Reset()

+ func (x *ListDispatchActivityResponse) String() string

+ type ListDispatchActivityResponseMultiError []error

+ func (m ListDispatchActivityResponseMultiError) AllErrors() []error

+ func (m ListDispatchActivityResponseMultiError) Error() string

+ type ListDispatchActivityResponseValidationError struct

+ func (e ListDispatchActivityResponseValidationError) Cause() error

+ func (e ListDispatchActivityResponseValidationError) Error() string

+ func (e ListDispatchActivityResponseValidationError) ErrorName() string

+ func (e ListDispatchActivityResponseValidationError) Field() string

+ func (e ListDispatchActivityResponseValidationError) Key() bool

+ func (e ListDispatchActivityResponseValidationError) Reason() string

+ type ListDispatchesRequest struct

+ NotStatus []dispatch.DISPATCH_STATUS

+ OwnOnly *bool

+ Status []dispatch.DISPATCH_STATUS

+ func (*ListDispatchesRequest) Descriptor() ([]byte, []int)

+ func (*ListDispatchesRequest) ProtoMessage()

+ func (m *ListDispatchesRequest) Validate() error

+ func (m *ListDispatchesRequest) ValidateAll() error

+ func (x *ListDispatchesRequest) GetNotStatus() []dispatch.DISPATCH_STATUS

+ func (x *ListDispatchesRequest) GetOwnOnly() bool

+ func (x *ListDispatchesRequest) GetStatus() []dispatch.DISPATCH_STATUS

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

+ func (x *ListDispatchesRequest) Reset()

+ func (x *ListDispatchesRequest) String() string

+ type ListDispatchesRequestMultiError []error

+ func (m ListDispatchesRequestMultiError) AllErrors() []error

+ func (m ListDispatchesRequestMultiError) Error() string

+ type ListDispatchesRequestValidationError struct

+ func (e ListDispatchesRequestValidationError) Cause() error

+ func (e ListDispatchesRequestValidationError) Error() string

+ func (e ListDispatchesRequestValidationError) ErrorName() string

+ func (e ListDispatchesRequestValidationError) Field() string

+ func (e ListDispatchesRequestValidationError) Key() bool

+ func (e ListDispatchesRequestValidationError) Reason() string

+ type ListDispatchesResponse struct

+ Dispatches []*dispatch.Dispatch

+ func (*ListDispatchesResponse) Descriptor() ([]byte, []int)

+ func (*ListDispatchesResponse) ProtoMessage()

+ func (m *ListDispatchesResponse) Validate() error

+ func (m *ListDispatchesResponse) ValidateAll() error

+ func (x *ListDispatchesResponse) GetDispatches() []*dispatch.Dispatch

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

+ func (x *ListDispatchesResponse) Reset()

+ func (x *ListDispatchesResponse) String() string

+ type ListDispatchesResponseMultiError []error

+ func (m ListDispatchesResponseMultiError) AllErrors() []error

+ func (m ListDispatchesResponseMultiError) Error() string

+ type ListDispatchesResponseValidationError struct

+ func (e ListDispatchesResponseValidationError) Cause() error

+ func (e ListDispatchesResponseValidationError) Error() string

+ func (e ListDispatchesResponseValidationError) ErrorName() string

+ func (e ListDispatchesResponseValidationError) Field() string

+ func (e ListDispatchesResponseValidationError) Key() bool

+ func (e ListDispatchesResponseValidationError) Reason() string

+ type ListUnitActivityRequest struct

+ Id uint64

+ Pagination *database.PaginationRequest

+ func (*ListUnitActivityRequest) Descriptor() ([]byte, []int)

+ func (*ListUnitActivityRequest) ProtoMessage()

+ func (m *ListUnitActivityRequest) Validate() error

+ func (m *ListUnitActivityRequest) ValidateAll() error

+ func (x *ListUnitActivityRequest) GetId() uint64

+ func (x *ListUnitActivityRequest) GetPagination() *database.PaginationRequest

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

+ func (x *ListUnitActivityRequest) Reset()

+ func (x *ListUnitActivityRequest) String() string

+ type ListUnitActivityRequestMultiError []error

+ func (m ListUnitActivityRequestMultiError) AllErrors() []error

+ func (m ListUnitActivityRequestMultiError) Error() string

+ type ListUnitActivityRequestValidationError struct

+ func (e ListUnitActivityRequestValidationError) Cause() error

+ func (e ListUnitActivityRequestValidationError) Error() string

+ func (e ListUnitActivityRequestValidationError) ErrorName() string

+ func (e ListUnitActivityRequestValidationError) Field() string

+ func (e ListUnitActivityRequestValidationError) Key() bool

+ func (e ListUnitActivityRequestValidationError) Reason() string

+ type ListUnitActivityResponse struct

+ Activity []*dispatch.UnitStatus

+ Pagination *database.PaginationResponse

+ func (*ListUnitActivityResponse) Descriptor() ([]byte, []int)

+ func (*ListUnitActivityResponse) ProtoMessage()

+ func (m *ListUnitActivityResponse) Validate() error

+ func (m *ListUnitActivityResponse) ValidateAll() error

+ func (x *ListUnitActivityResponse) GetActivity() []*dispatch.UnitStatus

+ func (x *ListUnitActivityResponse) GetPagination() *database.PaginationResponse

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

+ func (x *ListUnitActivityResponse) Reset()

+ func (x *ListUnitActivityResponse) String() string

+ type ListUnitActivityResponseMultiError []error

+ func (m ListUnitActivityResponseMultiError) AllErrors() []error

+ func (m ListUnitActivityResponseMultiError) Error() string

+ type ListUnitActivityResponseValidationError struct

+ func (e ListUnitActivityResponseValidationError) Cause() error

+ func (e ListUnitActivityResponseValidationError) Error() string

+ func (e ListUnitActivityResponseValidationError) ErrorName() string

+ func (e ListUnitActivityResponseValidationError) Field() string

+ func (e ListUnitActivityResponseValidationError) Key() bool

+ func (e ListUnitActivityResponseValidationError) Reason() string

type ListUnitsRequest

+ OwnOnly *bool

+ func (x *ListUnitsRequest) GetOwnOnly() bool

+ type Params struct

+ Audit audit.IAuditer

+ Config *config.Config

+ DB *sql.DB

+ Enricher *mstlystcdata.Enricher

+ Events *events.Eventus

+ LC fx.Lifecycle

+ Logger *zap.Logger

+ Perms perms.Permissions

+ TP *tracesdk.TracerProvider

+ Tracker *tracker.Tracker

type Server

+ func (s *Server) AssignDispatch(ctx context.Context, req *AssignDispatchRequest) (*AssignDispatchResponse, error)

+ func (s *Server) ConvertPhoneJobMsgToDispatch() error

+ func (s *Server) CreateDispatch(ctx context.Context, req *CreateDispatchRequest) (*CreateDispatchResponse, error)

+ func (s *Server) CreateOrUpdateUnit(ctx context.Context, req *CreateOrUpdateUnitRequest) (*CreateOrUpdateUnitResponse, error)

+ func (s *Server) GetSettings(ctx context.Context, req *GetSettingsRequest) (*dispatch.Settings, error)

+ func (s *Server) JoinUnit(ctx context.Context, req *JoinUnitRequest) (*JoinUnitResponse, error)

+ func (s *Server) ListDispatchActivity(ctx context.Context, req *ListDispatchActivityRequest) (*ListDispatchActivityResponse, error)

+ func (s *Server) ListDispatches(ctx context.Context, req *ListDispatchesRequest) (*ListDispatchesResponse, error)

+ func (s *Server) ListUnitActivity(ctx context.Context, req *ListUnitActivityRequest) (*ListUnitActivityResponse, error)

+ func (s *Server) RegisterServer(srv *grpc.Server)

+ func (s *Server) Stream(req *StreamRequest, srv CentrumService_StreamServer) error

+ func (s *Server) TakeControl(ctx context.Context, req *TakeControlRequest) (*TakeControlResponse, error)

+ func (s *Server) TakeDispatch(ctx context.Context, req *TakeDispatchRequest) (*TakeDispatchResponse, error)

+ func (s *Server) UpdateDispatch(ctx context.Context, req *UpdateDispatchRequest) (*UpdateDispatchResponse, error)

+ func (s *Server) UpdateDispatchStatus(ctx context.Context, req *UpdateDispatchStatusRequest) (*UpdateDispatchStatusResponse, error)

+ func (s *Server) UpdateSettings(ctx context.Context, req *dispatch.Settings) (*dispatch.Settings, error)

+ func (s *Server) UpdateUnitStatus(ctx context.Context, req *UpdateUnitStatusRequest) (*UpdateUnitStatusResponse, error)

+ type StreamRequest struct

+ func (*StreamRequest) Descriptor() ([]byte, []int)

+ func (*StreamRequest) ProtoMessage()

+ func (m *StreamRequest) Validate() error

+ func (m *StreamRequest) ValidateAll() error

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

+ func (x *StreamRequest) Reset()

+ func (x *StreamRequest) String() string

+ type StreamRequestMultiError []error

+ func (m StreamRequestMultiError) AllErrors() []error

+ func (m StreamRequestMultiError) Error() string

+ type StreamRequestValidationError struct

+ func (e StreamRequestValidationError) Cause() error

+ func (e StreamRequestValidationError) Error() string

+ func (e StreamRequestValidationError) ErrorName() string

+ func (e StreamRequestValidationError) Field() string

+ func (e StreamRequestValidationError) Key() bool

+ func (e StreamRequestValidationError) Reason() string

+ type StreamResponse struct

+ Change isStreamResponse_Change

+ Restart *bool

+ func (*StreamResponse) Descriptor() ([]byte, []int)

+ func (*StreamResponse) ProtoMessage()

+ func (m *StreamResponse) GetChange() isStreamResponse_Change

+ func (m *StreamResponse) Validate() error

+ func (m *StreamResponse) ValidateAll() error

+ func (x *StreamResponse) GetDispatchCreated() *dispatch.Dispatch

+ func (x *StreamResponse) GetDispatchDeleted() *dispatch.Dispatch

+ func (x *StreamResponse) GetDispatchStatus() *dispatch.Dispatch

+ func (x *StreamResponse) GetDispatchUpdated() *dispatch.Dispatch

+ func (x *StreamResponse) GetDisponents() *DisponentsChange

+ func (x *StreamResponse) GetLatestState() *LatestState

+ func (x *StreamResponse) GetRestart() bool

+ func (x *StreamResponse) GetSettings() *dispatch.Settings

+ func (x *StreamResponse) GetUnitAssigned() *dispatch.Unit

+ func (x *StreamResponse) GetUnitDeleted() *dispatch.Unit

+ func (x *StreamResponse) GetUnitStatus() *dispatch.Unit

+ func (x *StreamResponse) GetUnitUpdated() *dispatch.Unit

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

+ func (x *StreamResponse) Reset()

+ func (x *StreamResponse) String() string

+ type StreamResponseMultiError []error

+ func (m StreamResponseMultiError) AllErrors() []error

+ func (m StreamResponseMultiError) Error() string

+ type StreamResponseValidationError struct

+ func (e StreamResponseValidationError) Cause() error

+ func (e StreamResponseValidationError) Error() string

+ func (e StreamResponseValidationError) ErrorName() string

+ func (e StreamResponseValidationError) Field() string

+ func (e StreamResponseValidationError) Key() bool

+ func (e StreamResponseValidationError) Reason() string

+ type StreamResponse_DispatchCreated struct

+ DispatchCreated *dispatch.Dispatch

+ type StreamResponse_DispatchDeleted struct

+ DispatchDeleted *dispatch.Dispatch

+ type StreamResponse_DispatchStatus struct

+ DispatchStatus *dispatch.Dispatch

+ type StreamResponse_DispatchUpdated struct

+ DispatchUpdated *dispatch.Dispatch

+ type StreamResponse_Disponents struct

+ Disponents *DisponentsChange

+ type StreamResponse_LatestState struct

+ LatestState *LatestState

+ type StreamResponse_Settings struct

+ Settings *dispatch.Settings

+ type StreamResponse_UnitAssigned struct

+ UnitAssigned *dispatch.Unit

+ type StreamResponse_UnitDeleted struct

+ UnitDeleted *dispatch.Unit

+ type StreamResponse_UnitStatus struct

+ UnitStatus *dispatch.Unit

+ type StreamResponse_UnitUpdated struct

+ UnitUpdated *dispatch.Unit

+ type TAKE_DISPATCH_RESP int32

+ const TAKE_DISPATCH_RESP_ACCEPTED

+ const TAKE_DISPATCH_RESP_DECLINED

+ const TAKE_DISPATCH_RESP_TIMEOUT

+ func (TAKE_DISPATCH_RESP) Descriptor() protoreflect.EnumDescriptor

+ func (TAKE_DISPATCH_RESP) EnumDescriptor() ([]byte, []int)

+ func (TAKE_DISPATCH_RESP) Type() protoreflect.EnumType

+ func (x TAKE_DISPATCH_RESP) Enum() *TAKE_DISPATCH_RESP

+ func (x TAKE_DISPATCH_RESP) Number() protoreflect.EnumNumber

+ func (x TAKE_DISPATCH_RESP) String() string

+ type TakeControlRequest struct

+ Signon bool

+ func (*TakeControlRequest) Descriptor() ([]byte, []int)

+ func (*TakeControlRequest) ProtoMessage()

+ func (m *TakeControlRequest) Validate() error

+ func (m *TakeControlRequest) ValidateAll() error

+ func (x *TakeControlRequest) GetSignon() bool

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

+ func (x *TakeControlRequest) Reset()

+ func (x *TakeControlRequest) String() string

+ type TakeControlRequestMultiError []error

+ func (m TakeControlRequestMultiError) AllErrors() []error

+ func (m TakeControlRequestMultiError) Error() string

+ type TakeControlRequestValidationError struct

+ func (e TakeControlRequestValidationError) Cause() error

+ func (e TakeControlRequestValidationError) Error() string

+ func (e TakeControlRequestValidationError) ErrorName() string

+ func (e TakeControlRequestValidationError) Field() string

+ func (e TakeControlRequestValidationError) Key() bool

+ func (e TakeControlRequestValidationError) Reason() string

+ type TakeControlResponse struct

+ func (*TakeControlResponse) Descriptor() ([]byte, []int)

+ func (*TakeControlResponse) ProtoMessage()

+ func (m *TakeControlResponse) Validate() error

+ func (m *TakeControlResponse) ValidateAll() error

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

+ func (x *TakeControlResponse) Reset()

+ func (x *TakeControlResponse) String() string

+ type TakeControlResponseMultiError []error

+ func (m TakeControlResponseMultiError) AllErrors() []error

+ func (m TakeControlResponseMultiError) Error() string

+ type TakeControlResponseValidationError struct

+ func (e TakeControlResponseValidationError) Cause() error

+ func (e TakeControlResponseValidationError) Error() string

+ func (e TakeControlResponseValidationError) ErrorName() string

+ func (e TakeControlResponseValidationError) Field() string

+ func (e TakeControlResponseValidationError) Key() bool

+ func (e TakeControlResponseValidationError) Reason() string

+ type TakeDispatchRequest struct

+ DispatchIds []uint64

+ Reason *string

+ Resp TAKE_DISPATCH_RESP

+ func (*TakeDispatchRequest) Descriptor() ([]byte, []int)

+ func (*TakeDispatchRequest) ProtoMessage()

+ func (m *TakeDispatchRequest) Validate() error

+ func (m *TakeDispatchRequest) ValidateAll() error

+ func (x *TakeDispatchRequest) GetDispatchIds() []uint64

+ func (x *TakeDispatchRequest) GetReason() string

+ func (x *TakeDispatchRequest) GetResp() TAKE_DISPATCH_RESP

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

+ func (x *TakeDispatchRequest) Reset()

+ func (x *TakeDispatchRequest) String() string

+ type TakeDispatchRequestMultiError []error

+ func (m TakeDispatchRequestMultiError) AllErrors() []error

+ func (m TakeDispatchRequestMultiError) Error() string

+ type TakeDispatchRequestValidationError struct

+ func (e TakeDispatchRequestValidationError) Cause() error

+ func (e TakeDispatchRequestValidationError) Error() string

+ func (e TakeDispatchRequestValidationError) ErrorName() string

+ func (e TakeDispatchRequestValidationError) Field() string

+ func (e TakeDispatchRequestValidationError) Key() bool

+ func (e TakeDispatchRequestValidationError) Reason() string

+ type TakeDispatchResponse struct

+ func (*TakeDispatchResponse) Descriptor() ([]byte, []int)

+ func (*TakeDispatchResponse) ProtoMessage()

+ func (m *TakeDispatchResponse) Validate() error

+ func (m *TakeDispatchResponse) ValidateAll() error

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

+ func (x *TakeDispatchResponse) Reset()

+ func (x *TakeDispatchResponse) String() string

+ type TakeDispatchResponseMultiError []error

+ func (m TakeDispatchResponseMultiError) AllErrors() []error

+ func (m TakeDispatchResponseMultiError) Error() string

+ type TakeDispatchResponseValidationError struct

+ func (e TakeDispatchResponseValidationError) Cause() error

+ func (e TakeDispatchResponseValidationError) Error() string

+ func (e TakeDispatchResponseValidationError) ErrorName() string

+ func (e TakeDispatchResponseValidationError) Field() string

+ func (e TakeDispatchResponseValidationError) Key() bool

+ func (e TakeDispatchResponseValidationError) Reason() string

type UnimplementedCentrumServiceServer

+ func (UnimplementedCentrumServiceServer) AssignDispatch(context.Context, *AssignDispatchRequest) (*AssignDispatchResponse, error)

+ func (UnimplementedCentrumServiceServer) AssignUnit(context.Context, *AssignUnitRequest) (*AssignUnitResponse, error)

+ func (UnimplementedCentrumServiceServer) CreateOrUpdateUnit(context.Context, *CreateOrUpdateUnitRequest) (*CreateOrUpdateUnitResponse, error)

+ func (UnimplementedCentrumServiceServer) DeleteUnit(context.Context, *DeleteUnitRequest) (*DeleteUnitResponse, error)

+ func (UnimplementedCentrumServiceServer) GetSettings(context.Context, *GetSettingsRequest) (*dispatch.Settings, error)

+ func (UnimplementedCentrumServiceServer) JoinUnit(context.Context, *JoinUnitRequest) (*JoinUnitResponse, error)

+ func (UnimplementedCentrumServiceServer) ListDispatchActivity(context.Context, *ListDispatchActivityRequest) (*ListDispatchActivityResponse, error)

+ func (UnimplementedCentrumServiceServer) ListDispatches(context.Context, *ListDispatchesRequest) (*ListDispatchesResponse, error)

+ func (UnimplementedCentrumServiceServer) ListUnitActivity(context.Context, *ListUnitActivityRequest) (*ListUnitActivityResponse, error)

+ func (UnimplementedCentrumServiceServer) ListUnits(context.Context, *ListUnitsRequest) (*ListUnitsResponse, error)

+ func (UnimplementedCentrumServiceServer) TakeControl(context.Context, *TakeControlRequest) (*TakeControlResponse, error)

+ func (UnimplementedCentrumServiceServer) TakeDispatch(context.Context, *TakeDispatchRequest) (*TakeDispatchResponse, error)

+ func (UnimplementedCentrumServiceServer) UpdateDispatch(context.Context, *UpdateDispatchRequest) (*UpdateDispatchResponse, error)

+ func (UnimplementedCentrumServiceServer) UpdateDispatchStatus(context.Context, *UpdateDispatchStatusRequest) (*UpdateDispatchStatusResponse, error)

+ func (UnimplementedCentrumServiceServer) UpdateSettings(context.Context, *dispatch.Settings) (*dispatch.Settings, error)

+ func (UnimplementedCentrumServiceServer) UpdateUnitStatus(context.Context, *UpdateUnitStatusRequest) (*UpdateUnitStatusResponse, error)

+ type UpdateDispatchRequest struct

+ Dispatch *dispatch.Dispatch

+ func (*UpdateDispatchRequest) Descriptor() ([]byte, []int)

+ func (*UpdateDispatchRequest) ProtoMessage()

+ func (m *UpdateDispatchRequest) Validate() error

+ func (m *UpdateDispatchRequest) ValidateAll() error

+ func (x *UpdateDispatchRequest) GetDispatch() *dispatch.Dispatch

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

+ func (x *UpdateDispatchRequest) Reset()

+ func (x *UpdateDispatchRequest) String() string

+ type UpdateDispatchRequestMultiError []error

+ func (m UpdateDispatchRequestMultiError) AllErrors() []error

+ func (m UpdateDispatchRequestMultiError) Error() string

+ type UpdateDispatchRequestValidationError struct

+ func (e UpdateDispatchRequestValidationError) Cause() error

+ func (e UpdateDispatchRequestValidationError) Error() string

+ func (e UpdateDispatchRequestValidationError) ErrorName() string

+ func (e UpdateDispatchRequestValidationError) Field() string

+ func (e UpdateDispatchRequestValidationError) Key() bool

+ func (e UpdateDispatchRequestValidationError) Reason() string

+ type UpdateDispatchResponse struct

+ func (*UpdateDispatchResponse) Descriptor() ([]byte, []int)

+ func (*UpdateDispatchResponse) ProtoMessage()

+ func (m *UpdateDispatchResponse) Validate() error

+ func (m *UpdateDispatchResponse) ValidateAll() error

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

+ func (x *UpdateDispatchResponse) Reset()

+ func (x *UpdateDispatchResponse) String() string

+ type UpdateDispatchResponseMultiError []error

+ func (m UpdateDispatchResponseMultiError) AllErrors() []error

+ func (m UpdateDispatchResponseMultiError) Error() string

+ type UpdateDispatchResponseValidationError struct

+ func (e UpdateDispatchResponseValidationError) Cause() error

+ func (e UpdateDispatchResponseValidationError) Error() string

+ func (e UpdateDispatchResponseValidationError) ErrorName() string

+ func (e UpdateDispatchResponseValidationError) Field() string

+ func (e UpdateDispatchResponseValidationError) Key() bool

+ func (e UpdateDispatchResponseValidationError) Reason() string

+ type UpdateDispatchStatusRequest struct

+ Code *string

+ DispatchId uint64

+ Reason *string

+ Status dispatch.DISPATCH_STATUS

+ func (*UpdateDispatchStatusRequest) Descriptor() ([]byte, []int)

+ func (*UpdateDispatchStatusRequest) ProtoMessage()

+ func (m *UpdateDispatchStatusRequest) Validate() error

+ func (m *UpdateDispatchStatusRequest) ValidateAll() error

+ func (x *UpdateDispatchStatusRequest) GetCode() string

+ func (x *UpdateDispatchStatusRequest) GetDispatchId() uint64

+ func (x *UpdateDispatchStatusRequest) GetReason() string

+ func (x *UpdateDispatchStatusRequest) GetStatus() dispatch.DISPATCH_STATUS

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

+ func (x *UpdateDispatchStatusRequest) Reset()

+ func (x *UpdateDispatchStatusRequest) String() string

+ type UpdateDispatchStatusRequestMultiError []error

+ func (m UpdateDispatchStatusRequestMultiError) AllErrors() []error

+ func (m UpdateDispatchStatusRequestMultiError) Error() string

+ type UpdateDispatchStatusRequestValidationError struct

+ func (e UpdateDispatchStatusRequestValidationError) Cause() error

+ func (e UpdateDispatchStatusRequestValidationError) Error() string

+ func (e UpdateDispatchStatusRequestValidationError) ErrorName() string

+ func (e UpdateDispatchStatusRequestValidationError) Field() string

+ func (e UpdateDispatchStatusRequestValidationError) Key() bool

+ func (e UpdateDispatchStatusRequestValidationError) Reason() string

+ type UpdateDispatchStatusResponse struct

+ func (*UpdateDispatchStatusResponse) Descriptor() ([]byte, []int)

+ func (*UpdateDispatchStatusResponse) ProtoMessage()

+ func (m *UpdateDispatchStatusResponse) Validate() error

+ func (m *UpdateDispatchStatusResponse) ValidateAll() error

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

+ func (x *UpdateDispatchStatusResponse) Reset()

+ func (x *UpdateDispatchStatusResponse) String() string

+ type UpdateDispatchStatusResponseMultiError []error

+ func (m UpdateDispatchStatusResponseMultiError) AllErrors() []error

+ func (m UpdateDispatchStatusResponseMultiError) Error() string

+ type UpdateDispatchStatusResponseValidationError struct

+ func (e UpdateDispatchStatusResponseValidationError) Cause() error

+ func (e UpdateDispatchStatusResponseValidationError) Error() string

+ func (e UpdateDispatchStatusResponseValidationError) ErrorName() string

+ func (e UpdateDispatchStatusResponseValidationError) Field() string

+ func (e UpdateDispatchStatusResponseValidationError) Key() bool

+ func (e UpdateDispatchStatusResponseValidationError) Reason() string

+ type UpdateUnitStatusRequest struct

+ Code *string

+ Reason *string

+ Status dispatch.UNIT_STATUS

+ UnitId uint64

+ func (*UpdateUnitStatusRequest) Descriptor() ([]byte, []int)

+ func (*UpdateUnitStatusRequest) ProtoMessage()

+ func (m *UpdateUnitStatusRequest) Validate() error

+ func (m *UpdateUnitStatusRequest) ValidateAll() error

+ func (x *UpdateUnitStatusRequest) GetCode() string

+ func (x *UpdateUnitStatusRequest) GetReason() string

+ func (x *UpdateUnitStatusRequest) GetStatus() dispatch.UNIT_STATUS

+ func (x *UpdateUnitStatusRequest) GetUnitId() uint64

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

+ func (x *UpdateUnitStatusRequest) Reset()

+ func (x *UpdateUnitStatusRequest) String() string

+ type UpdateUnitStatusRequestMultiError []error

+ func (m UpdateUnitStatusRequestMultiError) AllErrors() []error

+ func (m UpdateUnitStatusRequestMultiError) Error() string

+ type UpdateUnitStatusRequestValidationError struct

+ func (e UpdateUnitStatusRequestValidationError) Cause() error

+ func (e UpdateUnitStatusRequestValidationError) Error() string

+ func (e UpdateUnitStatusRequestValidationError) ErrorName() string

+ func (e UpdateUnitStatusRequestValidationError) Field() string

+ func (e UpdateUnitStatusRequestValidationError) Key() bool

+ func (e UpdateUnitStatusRequestValidationError) Reason() string

+ type UpdateUnitStatusResponse struct

+ func (*UpdateUnitStatusResponse) Descriptor() ([]byte, []int)

+ func (*UpdateUnitStatusResponse) ProtoMessage()

+ func (m *UpdateUnitStatusResponse) Validate() error

+ func (m *UpdateUnitStatusResponse) ValidateAll() error

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

+ func (x *UpdateUnitStatusResponse) Reset()

+ func (x *UpdateUnitStatusResponse) String() string

+ type UpdateUnitStatusResponseMultiError []error

+ func (m UpdateUnitStatusResponseMultiError) AllErrors() []error

+ func (m UpdateUnitStatusResponseMultiError) Error() string

+ type UpdateUnitStatusResponseValidationError struct

+ func (e UpdateUnitStatusResponseValidationError) Cause() error

+ func (e UpdateUnitStatusResponseValidationError) Error() string

+ func (e UpdateUnitStatusResponseValidationError) ErrorName() string

+ func (e UpdateUnitStatusResponseValidationError) Field() string

+ func (e UpdateUnitStatusResponseValidationError) Key() bool

+ func (e UpdateUnitStatusResponseValidationError) Reason() string

v0.7.3

Jun 30, 2023

Changes in this version

+ const CentrumServiceCreateDispatchPerm

+ const CentrumServicePerm

+ const CentrumServiceStreamPerm

+ const UnitServiceAssignUnitAccessPermField

+ const UnitServiceAssignUnitPerm

+ const UnitServiceCreateUnitPerm

+ const UnitServiceDeleteUnitPerm

+ const UnitServiceListUnitsPerm

+ const UnitServicePerm

+ const UnitServiceStreamUnitsPerm

+ var CentrumService_ServiceDesc = grpc.ServiceDesc

+ var File_services_centrum_centrum_proto protoreflect.FileDescriptor

+ var PermsRemap = map[string]string

+ var UnitService_ServiceDesc = grpc.ServiceDesc

+ func RegisterCentrumServiceServer(s grpc.ServiceRegistrar, srv CentrumServiceServer)

+ func RegisterUnitServiceServer(s grpc.ServiceRegistrar, srv UnitServiceServer)

+ type AssignUnitRequest struct

+ ToAdd []int32

+ ToRemove []int32

+ UnitId uint64

+ func (*AssignUnitRequest) Descriptor() ([]byte, []int)

+ func (*AssignUnitRequest) ProtoMessage()

+ func (m *AssignUnitRequest) Validate() error

+ func (m *AssignUnitRequest) ValidateAll() error

+ func (x *AssignUnitRequest) GetToAdd() []int32

+ func (x *AssignUnitRequest) GetToRemove() []int32

+ func (x *AssignUnitRequest) GetUnitId() uint64

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

+ func (x *AssignUnitRequest) Reset()

+ func (x *AssignUnitRequest) String() string

+ type AssignUnitRequestMultiError []error

+ func (m AssignUnitRequestMultiError) AllErrors() []error

+ func (m AssignUnitRequestMultiError) Error() string

+ type AssignUnitRequestValidationError struct

+ func (e AssignUnitRequestValidationError) Cause() error

+ func (e AssignUnitRequestValidationError) Error() string

+ func (e AssignUnitRequestValidationError) ErrorName() string

+ func (e AssignUnitRequestValidationError) Field() string

+ func (e AssignUnitRequestValidationError) Key() bool

+ func (e AssignUnitRequestValidationError) Reason() string

+ type AssignUnitResponse struct

+ UnitId uint64

+ func (*AssignUnitResponse) Descriptor() ([]byte, []int)

+ func (*AssignUnitResponse) ProtoMessage()

+ func (m *AssignUnitResponse) Validate() error

+ func (m *AssignUnitResponse) ValidateAll() error

+ func (x *AssignUnitResponse) GetUnitId() uint64

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

+ func (x *AssignUnitResponse) Reset()

+ func (x *AssignUnitResponse) String() string

+ type AssignUnitResponseMultiError []error

+ func (m AssignUnitResponseMultiError) AllErrors() []error

+ func (m AssignUnitResponseMultiError) Error() string

+ type AssignUnitResponseValidationError struct

+ func (e AssignUnitResponseValidationError) Cause() error

+ func (e AssignUnitResponseValidationError) Error() string

+ func (e AssignUnitResponseValidationError) ErrorName() string

+ func (e AssignUnitResponseValidationError) Field() string

+ func (e AssignUnitResponseValidationError) Key() bool

+ func (e AssignUnitResponseValidationError) Reason() string

+ type CentrumServiceClient interface

+ CreateDispatch func(ctx context.Context, in *CreateDispatchRequest, opts ...grpc.CallOption) (*CreateDispatchResponse, error)

+ Stream func(ctx context.Context, in *CentrumStreamRequest, opts ...grpc.CallOption) (CentrumService_StreamClient, error)

+ func NewCentrumServiceClient(cc grpc.ClientConnInterface) CentrumServiceClient

+ func NewTestCentrumServiceClient(srv CentrumServiceServer) (CentrumServiceClient, context.Context, context.CancelFunc)

+ type CentrumServiceServer interface

+ CreateDispatch func(context.Context, *CreateDispatchRequest) (*CreateDispatchResponse, error)

+ Stream func(*CentrumStreamRequest, CentrumService_StreamServer) error

+ type CentrumService_StreamClient interface

+ Recv func() (*CentrumStreamResponse, error)

+ type CentrumService_StreamServer interface

+ Send func(*CentrumStreamResponse) error

+ type CentrumStreamRequest struct

+ func (*CentrumStreamRequest) Descriptor() ([]byte, []int)

+ func (*CentrumStreamRequest) ProtoMessage()

+ func (m *CentrumStreamRequest) Validate() error

+ func (m *CentrumStreamRequest) ValidateAll() error

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

+ func (x *CentrumStreamRequest) Reset()

+ func (x *CentrumStreamRequest) String() string

+ type CentrumStreamRequestMultiError []error

+ func (m CentrumStreamRequestMultiError) AllErrors() []error

+ func (m CentrumStreamRequestMultiError) Error() string

+ type CentrumStreamRequestValidationError struct

+ func (e CentrumStreamRequestValidationError) Cause() error

+ func (e CentrumStreamRequestValidationError) Error() string

+ func (e CentrumStreamRequestValidationError) ErrorName() string

+ func (e CentrumStreamRequestValidationError) Field() string

+ func (e CentrumStreamRequestValidationError) Key() bool

+ func (e CentrumStreamRequestValidationError) Reason() string

+ type CentrumStreamResponse struct

+ func (*CentrumStreamResponse) Descriptor() ([]byte, []int)

+ func (*CentrumStreamResponse) ProtoMessage()

+ func (m *CentrumStreamResponse) Validate() error

+ func (m *CentrumStreamResponse) ValidateAll() error

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

+ func (x *CentrumStreamResponse) Reset()

+ func (x *CentrumStreamResponse) String() string

+ type CentrumStreamResponseMultiError []error

+ func (m CentrumStreamResponseMultiError) AllErrors() []error

+ func (m CentrumStreamResponseMultiError) Error() string

+ type CentrumStreamResponseValidationError struct

+ func (e CentrumStreamResponseValidationError) Cause() error

+ func (e CentrumStreamResponseValidationError) Error() string

+ func (e CentrumStreamResponseValidationError) ErrorName() string

+ func (e CentrumStreamResponseValidationError) Field() string

+ func (e CentrumStreamResponseValidationError) Key() bool

+ func (e CentrumStreamResponseValidationError) Reason() string

+ type CreateDispatchRequest struct

+ func (*CreateDispatchRequest) Descriptor() ([]byte, []int)

+ func (*CreateDispatchRequest) ProtoMessage()

+ func (m *CreateDispatchRequest) Validate() error

+ func (m *CreateDispatchRequest) ValidateAll() error

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

+ func (x *CreateDispatchRequest) Reset()

+ func (x *CreateDispatchRequest) String() string

+ type CreateDispatchRequestMultiError []error

+ func (m CreateDispatchRequestMultiError) AllErrors() []error

+ func (m CreateDispatchRequestMultiError) Error() string

+ type CreateDispatchRequestValidationError struct

+ func (e CreateDispatchRequestValidationError) Cause() error

+ func (e CreateDispatchRequestValidationError) Error() string

+ func (e CreateDispatchRequestValidationError) ErrorName() string

+ func (e CreateDispatchRequestValidationError) Field() string

+ func (e CreateDispatchRequestValidationError) Key() bool

+ func (e CreateDispatchRequestValidationError) Reason() string

+ type CreateDispatchResponse struct

+ func (*CreateDispatchResponse) Descriptor() ([]byte, []int)

+ func (*CreateDispatchResponse) ProtoMessage()

+ func (m *CreateDispatchResponse) Validate() error

+ func (m *CreateDispatchResponse) ValidateAll() error

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

+ func (x *CreateDispatchResponse) Reset()

+ func (x *CreateDispatchResponse) String() string

+ type CreateDispatchResponseMultiError []error

+ func (m CreateDispatchResponseMultiError) AllErrors() []error

+ func (m CreateDispatchResponseMultiError) Error() string

+ type CreateDispatchResponseValidationError struct

+ func (e CreateDispatchResponseValidationError) Cause() error

+ func (e CreateDispatchResponseValidationError) Error() string

+ func (e CreateDispatchResponseValidationError) ErrorName() string

+ func (e CreateDispatchResponseValidationError) Field() string

+ func (e CreateDispatchResponseValidationError) Key() bool

+ func (e CreateDispatchResponseValidationError) Reason() string

+ type CreateUnitRequest struct

+ Unit *dispatch.Unit

+ func (*CreateUnitRequest) Descriptor() ([]byte, []int)

+ func (*CreateUnitRequest) ProtoMessage()

+ func (m *CreateUnitRequest) Validate() error

+ func (m *CreateUnitRequest) ValidateAll() error

+ func (x *CreateUnitRequest) GetUnit() *dispatch.Unit

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

+ func (x *CreateUnitRequest) Reset()

+ func (x *CreateUnitRequest) String() string

+ type CreateUnitRequestMultiError []error

+ func (m CreateUnitRequestMultiError) AllErrors() []error

+ func (m CreateUnitRequestMultiError) Error() string

+ type CreateUnitRequestValidationError struct

+ func (e CreateUnitRequestValidationError) Cause() error

+ func (e CreateUnitRequestValidationError) Error() string

+ func (e CreateUnitRequestValidationError) ErrorName() string

+ func (e CreateUnitRequestValidationError) Field() string

+ func (e CreateUnitRequestValidationError) Key() bool

+ func (e CreateUnitRequestValidationError) Reason() string

+ type CreateUnitResponse struct

+ Unit *dispatch.Unit

+ func (*CreateUnitResponse) Descriptor() ([]byte, []int)

+ func (*CreateUnitResponse) ProtoMessage()

+ func (m *CreateUnitResponse) Validate() error

+ func (m *CreateUnitResponse) ValidateAll() error

+ func (x *CreateUnitResponse) GetUnit() *dispatch.Unit

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

+ func (x *CreateUnitResponse) Reset()

+ func (x *CreateUnitResponse) String() string

+ type CreateUnitResponseMultiError []error

+ func (m CreateUnitResponseMultiError) AllErrors() []error

+ func (m CreateUnitResponseMultiError) Error() string

+ type CreateUnitResponseValidationError struct

+ func (e CreateUnitResponseValidationError) Cause() error

+ func (e CreateUnitResponseValidationError) Error() string

+ func (e CreateUnitResponseValidationError) ErrorName() string

+ func (e CreateUnitResponseValidationError) Field() string

+ func (e CreateUnitResponseValidationError) Key() bool

+ func (e CreateUnitResponseValidationError) Reason() string

+ type DeleteUnitRequest struct

+ UnitId uint64

+ func (*DeleteUnitRequest) Descriptor() ([]byte, []int)

+ func (*DeleteUnitRequest) ProtoMessage()

+ func (m *DeleteUnitRequest) Validate() error

+ func (m *DeleteUnitRequest) ValidateAll() error

+ func (x *DeleteUnitRequest) GetUnitId() uint64

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

+ func (x *DeleteUnitRequest) Reset()

+ func (x *DeleteUnitRequest) String() string

+ type DeleteUnitRequestMultiError []error

+ func (m DeleteUnitRequestMultiError) AllErrors() []error

+ func (m DeleteUnitRequestMultiError) Error() string

+ type DeleteUnitRequestValidationError struct

+ func (e DeleteUnitRequestValidationError) Cause() error

+ func (e DeleteUnitRequestValidationError) Error() string

+ func (e DeleteUnitRequestValidationError) ErrorName() string

+ func (e DeleteUnitRequestValidationError) Field() string

+ func (e DeleteUnitRequestValidationError) Key() bool

+ func (e DeleteUnitRequestValidationError) Reason() string

+ type DeleteUnitResponse struct

+ func (*DeleteUnitResponse) Descriptor() ([]byte, []int)

+ func (*DeleteUnitResponse) ProtoMessage()

+ func (m *DeleteUnitResponse) Validate() error

+ func (m *DeleteUnitResponse) ValidateAll() error

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

+ func (x *DeleteUnitResponse) Reset()

+ func (x *DeleteUnitResponse) String() string

+ type DeleteUnitResponseMultiError []error

+ func (m DeleteUnitResponseMultiError) AllErrors() []error

+ func (m DeleteUnitResponseMultiError) Error() string

+ type DeleteUnitResponseValidationError struct

+ func (e DeleteUnitResponseValidationError) Cause() error

+ func (e DeleteUnitResponseValidationError) Error() string

+ func (e DeleteUnitResponseValidationError) ErrorName() string

+ func (e DeleteUnitResponseValidationError) Field() string

+ func (e DeleteUnitResponseValidationError) Key() bool

+ func (e DeleteUnitResponseValidationError) Reason() string

+ type ListUnitsRequest struct

+ Name *string

+ Status []dispatch.UNIT_STATUS

+ func (*ListUnitsRequest) Descriptor() ([]byte, []int)

+ func (*ListUnitsRequest) ProtoMessage()

+ func (m *ListUnitsRequest) Validate() error

+ func (m *ListUnitsRequest) ValidateAll() error

+ func (x *ListUnitsRequest) GetName() string

+ func (x *ListUnitsRequest) GetStatus() []dispatch.UNIT_STATUS

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

+ func (x *ListUnitsRequest) Reset()

+ func (x *ListUnitsRequest) String() string

+ type ListUnitsRequestMultiError []error

+ func (m ListUnitsRequestMultiError) AllErrors() []error

+ func (m ListUnitsRequestMultiError) Error() string

+ type ListUnitsRequestValidationError struct

+ func (e ListUnitsRequestValidationError) Cause() error

+ func (e ListUnitsRequestValidationError) Error() string

+ func (e ListUnitsRequestValidationError) ErrorName() string

+ func (e ListUnitsRequestValidationError) Field() string

+ func (e ListUnitsRequestValidationError) Key() bool

+ func (e ListUnitsRequestValidationError) Reason() string

+ type ListUnitsResponse struct

+ Units []*dispatch.Unit

+ func (*ListUnitsResponse) Descriptor() ([]byte, []int)

+ func (*ListUnitsResponse) ProtoMessage()

+ func (m *ListUnitsResponse) Validate() error

+ func (m *ListUnitsResponse) ValidateAll() error

+ func (x *ListUnitsResponse) GetUnits() []*dispatch.Unit

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

+ func (x *ListUnitsResponse) Reset()

+ func (x *ListUnitsResponse) String() string

+ type ListUnitsResponseMultiError []error

+ func (m ListUnitsResponseMultiError) AllErrors() []error

+ func (m ListUnitsResponseMultiError) Error() string

+ type ListUnitsResponseValidationError struct

+ func (e ListUnitsResponseValidationError) Cause() error

+ func (e ListUnitsResponseValidationError) Error() string

+ func (e ListUnitsResponseValidationError) ErrorName() string

+ func (e ListUnitsResponseValidationError) Field() string

+ func (e ListUnitsResponseValidationError) Key() bool

+ func (e ListUnitsResponseValidationError) Reason() string

+ type Server struct

+ func NewServer(db *sql.DB, p perms.Permissions, aud audit.IAuditer) *Server

+ func (s *Server) AssignUnit(ctx context.Context, req *AssignUnitRequest) (*AssignUnitResponse, error)

+ func (s *Server) CreateUnit(ctx context.Context, req *CreateUnitRequest) (*CreateUnitResponse, error)

+ func (s *Server) DeleteUnit(ctx context.Context, req *DeleteUnitRequest) (*DeleteUnitResponse, error)

+ func (s *Server) GetPermsRemap() map[string]string

+ func (s *Server) ListUnits(ctx context.Context, req *ListUnitsRequest) (*ListUnitsResponse, error)

+ func (s *Server) StreamUnits(req *UnitStreamRequest, srv UnitService_StreamUnitsServer) error

+ func (s *Server) UpdateUnit(ctx context.Context, req *UpdateUnitRequest) (*UpdateUnitResponse, error)

+ type UnimplementedCentrumServiceServer struct

+ func (UnimplementedCentrumServiceServer) CreateDispatch(context.Context, *CreateDispatchRequest) (*CreateDispatchResponse, error)

+ func (UnimplementedCentrumServiceServer) Stream(*CentrumStreamRequest, CentrumService_StreamServer) error

+ type UnimplementedUnitServiceServer struct

+ func (UnimplementedUnitServiceServer) AssignUnit(context.Context, *AssignUnitRequest) (*AssignUnitResponse, error)

+ func (UnimplementedUnitServiceServer) CreateUnit(context.Context, *CreateUnitRequest) (*CreateUnitResponse, error)

+ func (UnimplementedUnitServiceServer) DeleteUnit(context.Context, *DeleteUnitRequest) (*DeleteUnitResponse, error)

+ func (UnimplementedUnitServiceServer) ListUnits(context.Context, *ListUnitsRequest) (*ListUnitsResponse, error)

+ func (UnimplementedUnitServiceServer) StreamUnits(*UnitStreamRequest, UnitService_StreamUnitsServer) error

+ func (UnimplementedUnitServiceServer) UpdateUnit(context.Context, *UpdateUnitRequest) (*UpdateUnitResponse, error)

+ type UnitChanges struct

+ Added []int32

+ Id uint64

+ Removed []int32

+ func (*UnitChanges) Descriptor() ([]byte, []int)

+ func (*UnitChanges) ProtoMessage()

+ func (m *UnitChanges) Validate() error

+ func (m *UnitChanges) ValidateAll() error

+ func (x *UnitChanges) GetAdded() []int32

+ func (x *UnitChanges) GetId() uint64

+ func (x *UnitChanges) GetRemoved() []int32

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

+ func (x *UnitChanges) Reset()

+ func (x *UnitChanges) String() string

+ type UnitChangesMultiError []error

+ func (m UnitChangesMultiError) AllErrors() []error

+ func (m UnitChangesMultiError) Error() string

+ type UnitChangesValidationError struct

+ func (e UnitChangesValidationError) Cause() error

+ func (e UnitChangesValidationError) Error() string

+ func (e UnitChangesValidationError) ErrorName() string

+ func (e UnitChangesValidationError) Field() string

+ func (e UnitChangesValidationError) Key() bool

+ func (e UnitChangesValidationError) Reason() string

+ type UnitServiceClient interface

+ AssignUnit func(ctx context.Context, in *AssignUnitRequest, opts ...grpc.CallOption) (*AssignUnitResponse, error)

+ CreateUnit func(ctx context.Context, in *CreateUnitRequest, opts ...grpc.CallOption) (*CreateUnitResponse, error)

+ DeleteUnit func(ctx context.Context, in *DeleteUnitRequest, opts ...grpc.CallOption) (*DeleteUnitResponse, error)

+ ListUnits func(ctx context.Context, in *ListUnitsRequest, opts ...grpc.CallOption) (*ListUnitsResponse, error)

+ StreamUnits func(ctx context.Context, in *UnitStreamRequest, opts ...grpc.CallOption) (UnitService_StreamUnitsClient, error)

+ UpdateUnit func(ctx context.Context, in *UpdateUnitRequest, opts ...grpc.CallOption) (*UpdateUnitResponse, error)

+ func NewTestUnitServiceClient(srv UnitServiceServer) (UnitServiceClient, context.Context, context.CancelFunc)

+ func NewUnitServiceClient(cc grpc.ClientConnInterface) UnitServiceClient

+ type UnitServiceServer interface

+ AssignUnit func(context.Context, *AssignUnitRequest) (*AssignUnitResponse, error)

+ CreateUnit func(context.Context, *CreateUnitRequest) (*CreateUnitResponse, error)

+ DeleteUnit func(context.Context, *DeleteUnitRequest) (*DeleteUnitResponse, error)

+ ListUnits func(context.Context, *ListUnitsRequest) (*ListUnitsResponse, error)

+ StreamUnits func(*UnitStreamRequest, UnitService_StreamUnitsServer) error

+ UpdateUnit func(context.Context, *UpdateUnitRequest) (*UpdateUnitResponse, error)

+ type UnitService_StreamUnitsClient interface

+ Recv func() (*UnitStreamResponse, error)

+ type UnitService_StreamUnitsServer interface

+ Send func(*UnitStreamResponse) error

+ type UnitStreamRequest struct

+ func (*UnitStreamRequest) Descriptor() ([]byte, []int)

+ func (*UnitStreamRequest) ProtoMessage()

+ func (m *UnitStreamRequest) Validate() error

+ func (m *UnitStreamRequest) ValidateAll() error

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

+ func (x *UnitStreamRequest) Reset()

+ func (x *UnitStreamRequest) String() string

+ type UnitStreamRequestMultiError []error

+ func (m UnitStreamRequestMultiError) AllErrors() []error

+ func (m UnitStreamRequestMultiError) Error() string

+ type UnitStreamRequestValidationError struct

+ func (e UnitStreamRequestValidationError) Cause() error

+ func (e UnitStreamRequestValidationError) Error() string

+ func (e UnitStreamRequestValidationError) ErrorName() string

+ func (e UnitStreamRequestValidationError) Field() string

+ func (e UnitStreamRequestValidationError) Key() bool

+ func (e UnitStreamRequestValidationError) Reason() string

+ type UnitStreamResponse struct

+ Changes []*UnitChanges

+ func (*UnitStreamResponse) Descriptor() ([]byte, []int)

+ func (*UnitStreamResponse) ProtoMessage()

+ func (m *UnitStreamResponse) Validate() error

+ func (m *UnitStreamResponse) ValidateAll() error

+ func (x *UnitStreamResponse) GetChanges() []*UnitChanges

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

+ func (x *UnitStreamResponse) Reset()

+ func (x *UnitStreamResponse) String() string

+ type UnitStreamResponseMultiError []error

+ func (m UnitStreamResponseMultiError) AllErrors() []error

+ func (m UnitStreamResponseMultiError) Error() string

+ type UnitStreamResponseValidationError struct

+ func (e UnitStreamResponseValidationError) Cause() error

+ func (e UnitStreamResponseValidationError) Error() string

+ func (e UnitStreamResponseValidationError) ErrorName() string

+ func (e UnitStreamResponseValidationError) Field() string

+ func (e UnitStreamResponseValidationError) Key() bool

+ func (e UnitStreamResponseValidationError) Reason() string

+ type UnsafeCentrumServiceServer interface

+ type UnsafeUnitServiceServer interface

+ type UpdateUnitRequest struct

+ Unit *dispatch.Unit

+ func (*UpdateUnitRequest) Descriptor() ([]byte, []int)

+ func (*UpdateUnitRequest) ProtoMessage()

+ func (m *UpdateUnitRequest) Validate() error

+ func (m *UpdateUnitRequest) ValidateAll() error

+ func (x *UpdateUnitRequest) GetUnit() *dispatch.Unit

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

+ func (x *UpdateUnitRequest) Reset()

+ func (x *UpdateUnitRequest) String() string

+ type UpdateUnitRequestMultiError []error

+ func (m UpdateUnitRequestMultiError) AllErrors() []error

+ func (m UpdateUnitRequestMultiError) Error() string

+ type UpdateUnitRequestValidationError struct

+ func (e UpdateUnitRequestValidationError) Cause() error

+ func (e UpdateUnitRequestValidationError) Error() string

+ func (e UpdateUnitRequestValidationError) ErrorName() string

+ func (e UpdateUnitRequestValidationError) Field() string

+ func (e UpdateUnitRequestValidationError) Key() bool

+ func (e UpdateUnitRequestValidationError) Reason() string

+ type UpdateUnitResponse struct

+ Unit *dispatch.Unit

+ func (*UpdateUnitResponse) Descriptor() ([]byte, []int)

+ func (*UpdateUnitResponse) ProtoMessage()

+ func (m *UpdateUnitResponse) Validate() error

+ func (m *UpdateUnitResponse) ValidateAll() error

+ func (x *UpdateUnitResponse) GetUnit() *dispatch.Unit

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

+ func (x *UpdateUnitResponse) Reset()

+ func (x *UpdateUnitResponse) String() string

+ type UpdateUnitResponseMultiError []error

+ func (m UpdateUnitResponseMultiError) AllErrors() []error

+ func (m UpdateUnitResponseMultiError) Error() string

+ type UpdateUnitResponseValidationError struct

+ func (e UpdateUnitResponseValidationError) Cause() error

+ func (e UpdateUnitResponseValidationError) Error() string

+ func (e UpdateUnitResponseValidationError) ErrorName() string

+ func (e UpdateUnitResponseValidationError) Field() string

+ func (e UpdateUnitResponseValidationError) Key() bool

+ func (e UpdateUnitResponseValidationError) Reason() string

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