Documentation
¶
Index ¶
- Variables
- func RegisterActivitySvcServer(s *grpc.Server, srv ActivitySvcServer)
- type Activity
- func (*Activity) Descriptor() ([]byte, []int)deprecated
- func (x *Activity) GetActType() *activitytypecomm.ActivityType
- func (x *Activity) GetCreationTime() *timestamp.Timestamp
- func (x *Activity) GetId() string
- func (x *Activity) GetOrder() *ordercomm.Order
- func (x *Activity) GetPeriod() *Interval
- func (*Activity) ProtoMessage()
- func (x *Activity) ProtoReflect() protoreflect.Message
- func (x *Activity) Reset()
- func (x *Activity) String() string
- type ActivitySvcClient
- type ActivitySvcServer
- type CreateActivityReply
- func (*CreateActivityReply) Descriptor() ([]byte, []int)deprecated
- func (x *CreateActivityReply) GetId() string
- func (*CreateActivityReply) ProtoMessage()
- func (x *CreateActivityReply) ProtoReflect() protoreflect.Message
- func (x *CreateActivityReply) Reset()
- func (x *CreateActivityReply) String() string
- type CreateActivityRequest
- func (*CreateActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateActivityRequest) GetActTypeID() string
- func (x *CreateActivityRequest) GetOrderID() string
- func (x *CreateActivityRequest) GetPeriod() *Interval
- func (*CreateActivityRequest) ProtoMessage()
- func (x *CreateActivityRequest) ProtoReflect() protoreflect.Message
- func (x *CreateActivityRequest) Reset()
- func (x *CreateActivityRequest) String() string
- type DeleteActivityReply
- type DeleteActivityRequest
- func (*DeleteActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteActivityRequest) GetId() string
- func (*DeleteActivityRequest) ProtoMessage()
- func (x *DeleteActivityRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteActivityRequest) Reset()
- func (x *DeleteActivityRequest) String() string
- type Interval
- func (*Interval) Descriptor() ([]byte, []int)deprecated
- func (x *Interval) GetFrom() *timestamp.Timestamp
- func (x *Interval) GetTo() *timestamp.Timestamp
- func (*Interval) ProtoMessage()
- func (x *Interval) ProtoReflect() protoreflect.Message
- func (x *Interval) Reset()
- func (x *Interval) String() string
- type ListActivitiesReply
- func (*ListActivitiesReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListActivitiesReply) GetActivities() []*Activity
- func (*ListActivitiesReply) ProtoMessage()
- func (x *ListActivitiesReply) ProtoReflect() protoreflect.Message
- func (x *ListActivitiesReply) Reset()
- func (x *ListActivitiesReply) String() string
- type ListActivitiesRequest
- func (*ListActivitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListActivitiesRequest) GetFilterIds() []string
- func (*ListActivitiesRequest) ProtoMessage()
- func (x *ListActivitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ListActivitiesRequest) Reset()
- func (x *ListActivitiesRequest) String() string
- type ListInIntervalActivitiesRequest
- func (*ListInIntervalActivitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListInIntervalActivitiesRequest) GetPeriod() *Interval
- func (*ListInIntervalActivitiesRequest) ProtoMessage()
- func (x *ListInIntervalActivitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ListInIntervalActivitiesRequest) Reset()
- func (x *ListInIntervalActivitiesRequest) String() string
- type ReadActivityReply
- func (*ReadActivityReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReadActivityReply) GetActivity() *Activity
- func (*ReadActivityReply) ProtoMessage()
- func (x *ReadActivityReply) ProtoReflect() protoreflect.Message
- func (x *ReadActivityReply) Reset()
- func (x *ReadActivityReply) String() string
- type ReadActivityRequest
- func (*ReadActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadActivityRequest) GetId() string
- func (*ReadActivityRequest) ProtoMessage()
- func (x *ReadActivityRequest) ProtoReflect() protoreflect.Message
- func (x *ReadActivityRequest) Reset()
- func (x *ReadActivityRequest) String() string
- type UnimplementedActivitySvcServer
- func (*UnimplementedActivitySvcServer) Create(context.Context, *CreateActivityRequest) (*CreateActivityReply, error)
- func (*UnimplementedActivitySvcServer) Delete(context.Context, *DeleteActivityRequest) (*DeleteActivityReply, error)
- func (*UnimplementedActivitySvcServer) List(context.Context, *ListActivitiesRequest) (*ListActivitiesReply, error)
- func (*UnimplementedActivitySvcServer) ListInInterval(context.Context, *ListInIntervalActivitiesRequest) (*ListActivitiesReply, error)
- func (*UnimplementedActivitySvcServer) Read(context.Context, *ReadActivityRequest) (*ReadActivityReply, error)
- func (*UnimplementedActivitySvcServer) Update(context.Context, *UpdateActivityRequest) (*UpdateActivityReply, error)
- type UpdateActivityReply
- type UpdateActivityRequest
- func (*UpdateActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateActivityRequest) GetActTypeID() string
- func (x *UpdateActivityRequest) GetId() string
- func (x *UpdateActivityRequest) GetOrderID() string
- func (x *UpdateActivityRequest) GetPeriod() *Interval
- func (*UpdateActivityRequest) ProtoMessage()
- func (x *UpdateActivityRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateActivityRequest) Reset()
- func (x *UpdateActivityRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var File_activitycomm_activity_proto protoreflect.FileDescriptor
Functions ¶
func RegisterActivitySvcServer ¶
func RegisterActivitySvcServer(s *grpc.Server, srv ActivitySvcServer)
Types ¶
type Activity ¶
type Activity struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` ActType *activitytypecomm.ActivityType `protobuf:"bytes,2,opt,name=ActType,proto3" json:"ActType,omitempty"` CreationTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=CreationTime,proto3" json:"CreationTime,omitempty"` Order *ordercomm.Order `protobuf:"bytes,4,opt,name=Order,proto3" json:"Order,omitempty"` Period *Interval `protobuf:"bytes,5,opt,name=Period,proto3" json:"Period,omitempty"` // contains filtered or unexported fields }
func (*Activity) Descriptor
deprecated
func (*Activity) GetActType ¶
func (x *Activity) GetActType() *activitytypecomm.ActivityType
func (*Activity) GetCreationTime ¶
func (*Activity) ProtoMessage ¶
func (*Activity) ProtoMessage()
func (*Activity) ProtoReflect ¶
func (x *Activity) ProtoReflect() protoreflect.Message
type ActivitySvcClient ¶
type ActivitySvcClient interface { // Creates a new activity Create(ctx context.Context, in *CreateActivityRequest, opts ...grpc.CallOption) (*CreateActivityReply, error) // Reads an activity Read(ctx context.Context, in *ReadActivityRequest, opts ...grpc.CallOption) (*ReadActivityReply, error) // Delete an activity Delete(ctx context.Context, in *DeleteActivityRequest, opts ...grpc.CallOption) (*DeleteActivityReply, error) // Update an activity Update(ctx context.Context, in *UpdateActivityRequest, opts ...grpc.CallOption) (*UpdateActivityReply, error) // List an activity List(ctx context.Context, in *ListActivitiesRequest, opts ...grpc.CallOption) (*ListActivitiesReply, error) // List an activity ListInInterval(ctx context.Context, in *ListInIntervalActivitiesRequest, opts ...grpc.CallOption) (*ListActivitiesReply, error) }
ActivitySvcClient is the client API for ActivitySvc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewActivitySvcClient ¶
func NewActivitySvcClient(cc grpc.ClientConnInterface) ActivitySvcClient
type ActivitySvcServer ¶
type ActivitySvcServer interface { // Creates a new activity Create(context.Context, *CreateActivityRequest) (*CreateActivityReply, error) // Reads an activity Read(context.Context, *ReadActivityRequest) (*ReadActivityReply, error) // Delete an activity Delete(context.Context, *DeleteActivityRequest) (*DeleteActivityReply, error) // Update an activity Update(context.Context, *UpdateActivityRequest) (*UpdateActivityReply, error) // List an activity List(context.Context, *ListActivitiesRequest) (*ListActivitiesReply, error) // List an activity ListInInterval(context.Context, *ListInIntervalActivitiesRequest) (*ListActivitiesReply, error) }
ActivitySvcServer is the server API for ActivitySvc service.
type CreateActivityReply ¶
type CreateActivityReply struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` // contains filtered or unexported fields }
The response message containing the id of the activity
func (*CreateActivityReply) Descriptor
deprecated
func (*CreateActivityReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateActivityReply.ProtoReflect.Descriptor instead.
func (*CreateActivityReply) GetId ¶
func (x *CreateActivityReply) GetId() string
func (*CreateActivityReply) ProtoMessage ¶
func (*CreateActivityReply) ProtoMessage()
func (*CreateActivityReply) ProtoReflect ¶
func (x *CreateActivityReply) ProtoReflect() protoreflect.Message
func (*CreateActivityReply) Reset ¶
func (x *CreateActivityReply) Reset()
func (*CreateActivityReply) String ¶
func (x *CreateActivityReply) String() string
type CreateActivityRequest ¶
type CreateActivityRequest struct { ActTypeID string `protobuf:"bytes,1,opt,name=ActTypeID,proto3" json:"ActTypeID,omitempty"` OrderID string `protobuf:"bytes,2,opt,name=OrderID,proto3" json:"OrderID,omitempty"` Period *Interval `protobuf:"bytes,3,opt,name=Period,proto3" json:"Period,omitempty"` // contains filtered or unexported fields }
The request message containing the activity details
func (*CreateActivityRequest) Descriptor
deprecated
func (*CreateActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateActivityRequest.ProtoReflect.Descriptor instead.
func (*CreateActivityRequest) GetActTypeID ¶
func (x *CreateActivityRequest) GetActTypeID() string
func (*CreateActivityRequest) GetOrderID ¶
func (x *CreateActivityRequest) GetOrderID() string
func (*CreateActivityRequest) GetPeriod ¶
func (x *CreateActivityRequest) GetPeriod() *Interval
func (*CreateActivityRequest) ProtoMessage ¶
func (*CreateActivityRequest) ProtoMessage()
func (*CreateActivityRequest) ProtoReflect ¶
func (x *CreateActivityRequest) ProtoReflect() protoreflect.Message
func (*CreateActivityRequest) Reset ¶
func (x *CreateActivityRequest) Reset()
func (*CreateActivityRequest) String ¶
func (x *CreateActivityRequest) String() string
type DeleteActivityReply ¶
type DeleteActivityReply struct {
// contains filtered or unexported fields
}
The response message to the delete request
func (*DeleteActivityReply) Descriptor
deprecated
func (*DeleteActivityReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteActivityReply.ProtoReflect.Descriptor instead.
func (*DeleteActivityReply) ProtoMessage ¶
func (*DeleteActivityReply) ProtoMessage()
func (*DeleteActivityReply) ProtoReflect ¶
func (x *DeleteActivityReply) ProtoReflect() protoreflect.Message
func (*DeleteActivityReply) Reset ¶
func (x *DeleteActivityReply) Reset()
func (*DeleteActivityReply) String ¶
func (x *DeleteActivityReply) String() string
type DeleteActivityRequest ¶
type DeleteActivityRequest struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` // contains filtered or unexported fields }
The request message for the delete request
func (*DeleteActivityRequest) Descriptor
deprecated
func (*DeleteActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteActivityRequest.ProtoReflect.Descriptor instead.
func (*DeleteActivityRequest) GetId ¶
func (x *DeleteActivityRequest) GetId() string
func (*DeleteActivityRequest) ProtoMessage ¶
func (*DeleteActivityRequest) ProtoMessage()
func (*DeleteActivityRequest) ProtoReflect ¶
func (x *DeleteActivityRequest) ProtoReflect() protoreflect.Message
func (*DeleteActivityRequest) Reset ¶
func (x *DeleteActivityRequest) Reset()
func (*DeleteActivityRequest) String ¶
func (x *DeleteActivityRequest) String() string
type Interval ¶
type Interval struct { From *timestamp.Timestamp `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"` To *timestamp.Timestamp `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"` // contains filtered or unexported fields }
func (*Interval) Descriptor
deprecated
func (*Interval) ProtoMessage ¶
func (*Interval) ProtoMessage()
func (*Interval) ProtoReflect ¶
func (x *Interval) ProtoReflect() protoreflect.Message
type ListActivitiesReply ¶
type ListActivitiesReply struct { Activities []*Activity `protobuf:"bytes,1,rep,name=activities,proto3" json:"activities,omitempty"` // contains filtered or unexported fields }
The response message to the list activities request.
func (*ListActivitiesReply) Descriptor
deprecated
func (*ListActivitiesReply) Descriptor() ([]byte, []int)
Deprecated: Use ListActivitiesReply.ProtoReflect.Descriptor instead.
func (*ListActivitiesReply) GetActivities ¶
func (x *ListActivitiesReply) GetActivities() []*Activity
func (*ListActivitiesReply) ProtoMessage ¶
func (*ListActivitiesReply) ProtoMessage()
func (*ListActivitiesReply) ProtoReflect ¶
func (x *ListActivitiesReply) ProtoReflect() protoreflect.Message
func (*ListActivitiesReply) Reset ¶
func (x *ListActivitiesReply) Reset()
func (*ListActivitiesReply) String ¶
func (x *ListActivitiesReply) String() string
type ListActivitiesRequest ¶
type ListActivitiesRequest struct { FilterIds []string `protobuf:"bytes,1,rep,name=FilterIds,proto3" json:"FilterIds,omitempty"` // contains filtered or unexported fields }
The request message for the list activities request
func (*ListActivitiesRequest) Descriptor
deprecated
func (*ListActivitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActivitiesRequest.ProtoReflect.Descriptor instead.
func (*ListActivitiesRequest) GetFilterIds ¶
func (x *ListActivitiesRequest) GetFilterIds() []string
func (*ListActivitiesRequest) ProtoMessage ¶
func (*ListActivitiesRequest) ProtoMessage()
func (*ListActivitiesRequest) ProtoReflect ¶
func (x *ListActivitiesRequest) ProtoReflect() protoreflect.Message
func (*ListActivitiesRequest) Reset ¶
func (x *ListActivitiesRequest) Reset()
func (*ListActivitiesRequest) String ¶
func (x *ListActivitiesRequest) String() string
type ListInIntervalActivitiesRequest ¶
type ListInIntervalActivitiesRequest struct { Period *Interval `protobuf:"bytes,1,opt,name=Period,proto3" json:"Period,omitempty"` // contains filtered or unexported fields }
func (*ListInIntervalActivitiesRequest) Descriptor
deprecated
func (*ListInIntervalActivitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListInIntervalActivitiesRequest.ProtoReflect.Descriptor instead.
func (*ListInIntervalActivitiesRequest) GetPeriod ¶
func (x *ListInIntervalActivitiesRequest) GetPeriod() *Interval
func (*ListInIntervalActivitiesRequest) ProtoMessage ¶
func (*ListInIntervalActivitiesRequest) ProtoMessage()
func (*ListInIntervalActivitiesRequest) ProtoReflect ¶
func (x *ListInIntervalActivitiesRequest) ProtoReflect() protoreflect.Message
func (*ListInIntervalActivitiesRequest) Reset ¶
func (x *ListInIntervalActivitiesRequest) Reset()
func (*ListInIntervalActivitiesRequest) String ¶
func (x *ListInIntervalActivitiesRequest) String() string
type ReadActivityReply ¶
type ReadActivityReply struct { Activity *Activity `protobuf:"bytes,1,opt,name=activity,proto3" json:"activity,omitempty"` // contains filtered or unexported fields }
The response message to the read request
func (*ReadActivityReply) Descriptor
deprecated
func (*ReadActivityReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadActivityReply.ProtoReflect.Descriptor instead.
func (*ReadActivityReply) GetActivity ¶
func (x *ReadActivityReply) GetActivity() *Activity
func (*ReadActivityReply) ProtoMessage ¶
func (*ReadActivityReply) ProtoMessage()
func (*ReadActivityReply) ProtoReflect ¶
func (x *ReadActivityReply) ProtoReflect() protoreflect.Message
func (*ReadActivityReply) Reset ¶
func (x *ReadActivityReply) Reset()
func (*ReadActivityReply) String ¶
func (x *ReadActivityReply) String() string
type ReadActivityRequest ¶
type ReadActivityRequest struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` // contains filtered or unexported fields }
The request message for the read request
func (*ReadActivityRequest) Descriptor
deprecated
func (*ReadActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadActivityRequest.ProtoReflect.Descriptor instead.
func (*ReadActivityRequest) GetId ¶
func (x *ReadActivityRequest) GetId() string
func (*ReadActivityRequest) ProtoMessage ¶
func (*ReadActivityRequest) ProtoMessage()
func (*ReadActivityRequest) ProtoReflect ¶
func (x *ReadActivityRequest) ProtoReflect() protoreflect.Message
func (*ReadActivityRequest) Reset ¶
func (x *ReadActivityRequest) Reset()
func (*ReadActivityRequest) String ¶
func (x *ReadActivityRequest) String() string
type UnimplementedActivitySvcServer ¶
type UnimplementedActivitySvcServer struct { }
UnimplementedActivitySvcServer can be embedded to have forward compatible implementations.
func (*UnimplementedActivitySvcServer) Create ¶
func (*UnimplementedActivitySvcServer) Create(context.Context, *CreateActivityRequest) (*CreateActivityReply, error)
func (*UnimplementedActivitySvcServer) Delete ¶
func (*UnimplementedActivitySvcServer) Delete(context.Context, *DeleteActivityRequest) (*DeleteActivityReply, error)
func (*UnimplementedActivitySvcServer) List ¶
func (*UnimplementedActivitySvcServer) List(context.Context, *ListActivitiesRequest) (*ListActivitiesReply, error)
func (*UnimplementedActivitySvcServer) ListInInterval ¶
func (*UnimplementedActivitySvcServer) ListInInterval(context.Context, *ListInIntervalActivitiesRequest) (*ListActivitiesReply, error)
func (*UnimplementedActivitySvcServer) Read ¶
func (*UnimplementedActivitySvcServer) Read(context.Context, *ReadActivityRequest) (*ReadActivityReply, error)
func (*UnimplementedActivitySvcServer) Update ¶
func (*UnimplementedActivitySvcServer) Update(context.Context, *UpdateActivityRequest) (*UpdateActivityReply, error)
type UpdateActivityReply ¶
type UpdateActivityReply struct {
// contains filtered or unexported fields
}
The response message to the update request. Returns the old values for the Activity
func (*UpdateActivityReply) Descriptor
deprecated
func (*UpdateActivityReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateActivityReply.ProtoReflect.Descriptor instead.
func (*UpdateActivityReply) ProtoMessage ¶
func (*UpdateActivityReply) ProtoMessage()
func (*UpdateActivityReply) ProtoReflect ¶
func (x *UpdateActivityReply) ProtoReflect() protoreflect.Message
func (*UpdateActivityReply) Reset ¶
func (x *UpdateActivityReply) Reset()
func (*UpdateActivityReply) String ¶
func (x *UpdateActivityReply) String() string
type UpdateActivityRequest ¶
type UpdateActivityRequest struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` ActTypeID string `protobuf:"bytes,2,opt,name=ActTypeID,proto3" json:"ActTypeID,omitempty"` OrderID string `protobuf:"bytes,3,opt,name=OrderID,proto3" json:"OrderID,omitempty"` Period *Interval `protobuf:"bytes,4,opt,name=Period,proto3" json:"Period,omitempty"` // contains filtered or unexported fields }
The request message for the update request
func (*UpdateActivityRequest) Descriptor
deprecated
func (*UpdateActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateActivityRequest.ProtoReflect.Descriptor instead.
func (*UpdateActivityRequest) GetActTypeID ¶
func (x *UpdateActivityRequest) GetActTypeID() string
func (*UpdateActivityRequest) GetId ¶
func (x *UpdateActivityRequest) GetId() string
func (*UpdateActivityRequest) GetOrderID ¶
func (x *UpdateActivityRequest) GetOrderID() string
func (*UpdateActivityRequest) GetPeriod ¶
func (x *UpdateActivityRequest) GetPeriod() *Interval
func (*UpdateActivityRequest) ProtoMessage ¶
func (*UpdateActivityRequest) ProtoMessage()
func (*UpdateActivityRequest) ProtoReflect ¶
func (x *UpdateActivityRequest) ProtoReflect() protoreflect.Message
func (*UpdateActivityRequest) Reset ¶
func (x *UpdateActivityRequest) Reset()
func (*UpdateActivityRequest) String ¶
func (x *UpdateActivityRequest) String() string