stk

package
v1.1.0 Latest Latest
Warning

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

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

Documentation

Overview

Package stk is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_stk_proto protoreflect.FileDescriptor

Functions

func RegisterStkPushAPIHandler 

func RegisterStkPushAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStkPushAPIHandler registers the http handlers for service StkPushAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStkPushAPIHandlerClient 

func RegisterStkPushAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StkPushAPIClient) error

RegisterStkPushAPIHandlerClient registers the http handlers for service StkPushAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StkPushAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StkPushAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StkPushAPIClient" to call the correct interceptors.

func RegisterStkPushAPIHandlerFromEndpoint 

func RegisterStkPushAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStkPushAPIHandlerFromEndpoint is same as RegisterStkPushAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStkPushAPIHandlerServer 

func RegisterStkPushAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StkPushAPIServer) error

RegisterStkPushAPIHandlerServer registers the http handlers for service StkPushAPI to "mux". UnaryRPC :call StkPushAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStkPushAPIHandlerFromEndpoint instead.

func RegisterStkPushAPIServer 

func RegisterStkPushAPIServer(s grpc.ServiceRegistrar, srv StkPushAPIServer)

Types

type CreateStkPayloadRequest 

type CreateStkPayloadRequest struct {
	Payload *StkPayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Publish bool        `protobuf:"varint,2,opt,name=publish,proto3" json:"publish,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStkPayloadRequest) Descriptor deprecated 

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

Deprecated: Use CreateStkPayloadRequest.ProtoReflect.Descriptor instead.

func (*CreateStkPayloadRequest) GetPayload 

func (x *CreateStkPayloadRequest) GetPayload() *StkPayload

func (*CreateStkPayloadRequest) GetPublish 

func (x *CreateStkPayloadRequest) GetPublish() bool

func (*CreateStkPayloadRequest) ProtoMessage 

func (*CreateStkPayloadRequest) ProtoMessage()

func (*CreateStkPayloadRequest) ProtoReflect 

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

func (*CreateStkPayloadRequest) Reset 

func (x *CreateStkPayloadRequest) Reset()

func (*CreateStkPayloadRequest) String 

func (x *CreateStkPayloadRequest) String() string

type GetStkPayloadRequest 

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

func (*GetStkPayloadRequest) Descriptor deprecated 

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

Deprecated: Use GetStkPayloadRequest.ProtoReflect.Descriptor instead.

func (*GetStkPayloadRequest) GetPayloadId 

func (x *GetStkPayloadRequest) GetPayloadId() string

func (*GetStkPayloadRequest) ProtoMessage 

func (*GetStkPayloadRequest) ProtoMessage()

func (*GetStkPayloadRequest) ProtoReflect 

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

func (*GetStkPayloadRequest) Reset 

func (x *GetStkPayloadRequest) Reset()

func (*GetStkPayloadRequest) String 

func (x *GetStkPayloadRequest) String() string

type InitiateSTKPushRequest 

type InitiateSTKPushRequest struct {
	InitiatorId string            `protobuf:"bytes,1,opt,name=initiator_id,json=initiatorId,proto3" json:"initiator_id,omitempty"`
	Phone       string            `protobuf:"bytes,2,opt,name=phone,proto3" json:"phone,omitempty"`
	Amount      float64           `protobuf:"fixed64,3,opt,name=amount,proto3" json:"amount,omitempty"`
	Payload     map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InitiateSTKPushRequest) Descriptor deprecated 

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

Deprecated: Use InitiateSTKPushRequest.ProtoReflect.Descriptor instead.

func (*InitiateSTKPushRequest) GetAmount 

func (x *InitiateSTKPushRequest) GetAmount() float64

func (*InitiateSTKPushRequest) GetInitiatorId 

func (x *InitiateSTKPushRequest) GetInitiatorId() string

func (*InitiateSTKPushRequest) GetPayload 

func (x *InitiateSTKPushRequest) GetPayload() map[string]string

func (*InitiateSTKPushRequest) GetPhone 

func (x *InitiateSTKPushRequest) GetPhone() string

func (*InitiateSTKPushRequest) ProtoMessage 

func (*InitiateSTKPushRequest) ProtoMessage()

func (*InitiateSTKPushRequest) ProtoReflect 

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

func (*InitiateSTKPushRequest) Reset 

func (x *InitiateSTKPushRequest) Reset()

func (*InitiateSTKPushRequest) String 

func (x *InitiateSTKPushRequest) String() string

type InitiateSTKPushResponse 

type InitiateSTKPushResponse struct {
	Progress bool   `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"`
	Message  string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*InitiateSTKPushResponse) Descriptor deprecated 

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

Deprecated: Use InitiateSTKPushResponse.ProtoReflect.Descriptor instead.

func (*InitiateSTKPushResponse) GetMessage 

func (x *InitiateSTKPushResponse) GetMessage() string

func (*InitiateSTKPushResponse) GetProgress 

func (x *InitiateSTKPushResponse) GetProgress() bool

func (*InitiateSTKPushResponse) ProtoMessage 

func (*InitiateSTKPushResponse) ProtoMessage()

func (*InitiateSTKPushResponse) ProtoReflect 

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

func (*InitiateSTKPushResponse) Reset 

func (x *InitiateSTKPushResponse) Reset()

func (*InitiateSTKPushResponse) String 

func (x *InitiateSTKPushResponse) String() string

type ListStkPayloadFilter 

type ListStkPayloadFilter struct {
	TxDate         string             `protobuf:"bytes,1,opt,name=tx_date,json=txDate,proto3" json:"tx_date,omitempty"`
	Msisdns        []string           `protobuf:"bytes,2,rep,name=msisdns,proto3" json:"msisdns,omitempty"`
	ProcessState   c2b.ProcessedState `` /* 131-byte string literal not displayed */
	StartTimestamp int64              `protobuf:"varint,4,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp   int64              `protobuf:"varint,5,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStkPayloadFilter) Descriptor deprecated 

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

Deprecated: Use ListStkPayloadFilter.ProtoReflect.Descriptor instead.

func (*ListStkPayloadFilter) GetEndTimestamp 

func (x *ListStkPayloadFilter) GetEndTimestamp() int64

func (*ListStkPayloadFilter) GetMsisdns 

func (x *ListStkPayloadFilter) GetMsisdns() []string

func (*ListStkPayloadFilter) GetProcessState 

func (x *ListStkPayloadFilter) GetProcessState() c2b.ProcessedState

func (*ListStkPayloadFilter) GetStartTimestamp 

func (x *ListStkPayloadFilter) GetStartTimestamp() int64

func (*ListStkPayloadFilter) GetTxDate 

func (x *ListStkPayloadFilter) GetTxDate() string

func (*ListStkPayloadFilter) ProtoMessage 

func (*ListStkPayloadFilter) ProtoMessage()

func (*ListStkPayloadFilter) ProtoReflect 

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

func (*ListStkPayloadFilter) Reset 

func (x *ListStkPayloadFilter) Reset()

func (*ListStkPayloadFilter) String 

func (x *ListStkPayloadFilter) String() string

type ListStkPayloadsRequest 

type ListStkPayloadsRequest struct {
	PageToken string                `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize  int32                 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Filter    *ListStkPayloadFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStkPayloadsRequest) Descriptor deprecated 

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

Deprecated: Use ListStkPayloadsRequest.ProtoReflect.Descriptor instead.

func (*ListStkPayloadsRequest) GetFilter 

func (x *ListStkPayloadsRequest) GetFilter() *ListStkPayloadFilter

func (*ListStkPayloadsRequest) GetPageSize 

func (x *ListStkPayloadsRequest) GetPageSize() int32

func (*ListStkPayloadsRequest) GetPageToken 

func (x *ListStkPayloadsRequest) GetPageToken() string

func (*ListStkPayloadsRequest) ProtoMessage 

func (*ListStkPayloadsRequest) ProtoMessage()

func (*ListStkPayloadsRequest) ProtoReflect 

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

func (*ListStkPayloadsRequest) Reset 

func (x *ListStkPayloadsRequest) Reset()

func (*ListStkPayloadsRequest) String 

func (x *ListStkPayloadsRequest) String() string

type ListStkPayloadsResponse 

type ListStkPayloadsResponse struct {
	NextPageToken string        `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	StkPayloads   []*StkPayload `protobuf:"bytes,2,rep,name=stk_payloads,json=stkPayloads,proto3" json:"stk_payloads,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStkPayloadsResponse) Descriptor deprecated 

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

Deprecated: Use ListStkPayloadsResponse.ProtoReflect.Descriptor instead.

func (*ListStkPayloadsResponse) GetNextPageToken 

func (x *ListStkPayloadsResponse) GetNextPageToken() string

func (*ListStkPayloadsResponse) GetStkPayloads 

func (x *ListStkPayloadsResponse) GetStkPayloads() []*StkPayload

func (*ListStkPayloadsResponse) ProtoMessage 

func (*ListStkPayloadsResponse) ProtoMessage()

func (*ListStkPayloadsResponse) ProtoReflect 

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

func (*ListStkPayloadsResponse) Reset 

func (x *ListStkPayloadsResponse) Reset()

func (*ListStkPayloadsResponse) String 

func (x *ListStkPayloadsResponse) String() string

type ProcessStkPayloadRequest 

type ProcessStkPayloadRequest struct {
	PayloadId string `protobuf:"bytes,1,opt,name=payload_id,json=payloadId,proto3" json:"payload_id,omitempty"`
	Processed bool   `protobuf:"varint,2,opt,name=processed,proto3" json:"processed,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessStkPayloadRequest) Descriptor deprecated 

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

Deprecated: Use ProcessStkPayloadRequest.ProtoReflect.Descriptor instead.

func (*ProcessStkPayloadRequest) GetPayloadId 

func (x *ProcessStkPayloadRequest) GetPayloadId() string

func (*ProcessStkPayloadRequest) GetProcessed 

func (x *ProcessStkPayloadRequest) GetProcessed() bool

func (*ProcessStkPayloadRequest) ProtoMessage 

func (*ProcessStkPayloadRequest) ProtoMessage()

func (*ProcessStkPayloadRequest) ProtoReflect 

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

func (*ProcessStkPayloadRequest) Reset 

func (x *ProcessStkPayloadRequest) Reset()

func (*ProcessStkPayloadRequest) String 

func (x *ProcessStkPayloadRequest) String() string

type PublishAllStkPayloadRequest 

type PublishAllStkPayloadRequest struct {
	ProcessedState c2b.ProcessedState `` /* 137-byte string literal not displayed */
	FromCache      bool               `protobuf:"varint,2,opt,name=from_cache,json=fromCache,proto3" json:"from_cache,omitempty"`
	StartTimestamp int64              `protobuf:"varint,3,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp   int64              `protobuf:"varint,4,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishAllStkPayloadRequest) Descriptor deprecated 

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

Deprecated: Use PublishAllStkPayloadRequest.ProtoReflect.Descriptor instead.

func (*PublishAllStkPayloadRequest) GetEndTimestamp 

func (x *PublishAllStkPayloadRequest) GetEndTimestamp() int64

func (*PublishAllStkPayloadRequest) GetFromCache 

func (x *PublishAllStkPayloadRequest) GetFromCache() bool

func (*PublishAllStkPayloadRequest) GetProcessedState 

func (x *PublishAllStkPayloadRequest) GetProcessedState() c2b.ProcessedState

func (*PublishAllStkPayloadRequest) GetStartTimestamp 

func (x *PublishAllStkPayloadRequest) GetStartTimestamp() int64

func (*PublishAllStkPayloadRequest) ProtoMessage 

func (*PublishAllStkPayloadRequest) ProtoMessage()

func (*PublishAllStkPayloadRequest) ProtoReflect 

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

func (*PublishAllStkPayloadRequest) Reset 

func (x *PublishAllStkPayloadRequest) Reset()

func (*PublishAllStkPayloadRequest) String 

func (x *PublishAllStkPayloadRequest) String() string

type PublishMessage 

type PublishMessage struct {
	PayloadId string            `protobuf:"bytes,1,opt,name=payload_id,json=payloadId,proto3" json:"payload_id,omitempty"`
	Payload   map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PublishMessage) Descriptor deprecated 

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

Deprecated: Use PublishMessage.ProtoReflect.Descriptor instead.

func (*PublishMessage) GetPayload 

func (x *PublishMessage) GetPayload() map[string]string

func (*PublishMessage) GetPayloadId 

func (x *PublishMessage) GetPayloadId() string

func (*PublishMessage) ProtoMessage 

func (*PublishMessage) ProtoMessage()

func (*PublishMessage) ProtoReflect 

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

func (*PublishMessage) Reset 

func (x *PublishMessage) Reset()

func (*PublishMessage) String 

func (x *PublishMessage) String() string

type PublishStkPayloadRequest 

type PublishStkPayloadRequest struct {
	PayloadId      string             `protobuf:"bytes,1,opt,name=payload_id,json=payloadId,proto3" json:"payload_id,omitempty"`
	Payload        map[string]string  `` /* 155-byte string literal not displayed */
	ProcessedState c2b.ProcessedState `` /* 137-byte string literal not displayed */
	FromCache      bool               `protobuf:"varint,4,opt,name=from_cache,json=fromCache,proto3" json:"from_cache,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStkPayloadRequest) Descriptor deprecated 

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

Deprecated: Use PublishStkPayloadRequest.ProtoReflect.Descriptor instead.

func (*PublishStkPayloadRequest) GetFromCache 

func (x *PublishStkPayloadRequest) GetFromCache() bool

func (*PublishStkPayloadRequest) GetPayload 

func (x *PublishStkPayloadRequest) GetPayload() map[string]string

func (*PublishStkPayloadRequest) GetPayloadId 

func (x *PublishStkPayloadRequest) GetPayloadId() string

func (*PublishStkPayloadRequest) GetProcessedState 

func (x *PublishStkPayloadRequest) GetProcessedState() c2b.ProcessedState

func (*PublishStkPayloadRequest) ProtoMessage 

func (*PublishStkPayloadRequest) ProtoMessage()

func (*PublishStkPayloadRequest) ProtoReflect 

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

func (*PublishStkPayloadRequest) Reset 

func (x *PublishStkPayloadRequest) Reset()

func (*PublishStkPayloadRequest) String 

func (x *PublishStkPayloadRequest) String() string

type StkPayload 

type StkPayload struct {
	InitiatorId          string `protobuf:"bytes,1,opt,name=initiator_id,json=initiatorId,proto3" json:"initiator_id,omitempty"`
	PayloadId            string `protobuf:"bytes,2,opt,name=payload_id,json=payloadId,proto3" json:"payload_id,omitempty"`
	MerchantRequestId    string `protobuf:"bytes,3,opt,name=merchant_request_id,json=merchantRequestId,proto3" json:"merchant_request_id,omitempty"`
	CheckoutRequestId    string `protobuf:"bytes,4,opt,name=checkout_request_id,json=checkoutRequestId,proto3" json:"checkout_request_id,omitempty"`
	ResultCode           string `protobuf:"bytes,5,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
	ResultDesc           string `protobuf:"bytes,6,opt,name=result_desc,json=resultDesc,proto3" json:"result_desc,omitempty"`
	Amount               string `protobuf:"bytes,7,opt,name=amount,proto3" json:"amount,omitempty"`
	TransactionId        string `protobuf:"bytes,8,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Balance              string `protobuf:"bytes,9,opt,name=balance,proto3" json:"balance,omitempty"`
	PhoneNumber          string `protobuf:"bytes,11,opt,name=phone_number,json=phoneNumber,proto3" json:"phone_number,omitempty"`
	Succeeded            bool   `protobuf:"varint,12,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Processed            bool   `protobuf:"varint,13,opt,name=processed,proto3" json:"processed,omitempty"`
	TransactionTimestamp int64  `protobuf:"varint,14,opt,name=transaction_timestamp,json=transactionTimestamp,proto3" json:"transaction_timestamp,omitempty"`
	CreateTimestamp      int64  `protobuf:"varint,15,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StkPayload) Descriptor deprecated 

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

Deprecated: Use StkPayload.ProtoReflect.Descriptor instead.

func (*StkPayload) GetAmount 

func (x *StkPayload) GetAmount() string

func (*StkPayload) GetBalance 

func (x *StkPayload) GetBalance() string

func (*StkPayload) GetCheckoutRequestId 

func (x *StkPayload) GetCheckoutRequestId() string

func (*StkPayload) GetCreateTimestamp 

func (x *StkPayload) GetCreateTimestamp() int64

func (*StkPayload) GetInitiatorId 

func (x *StkPayload) GetInitiatorId() string

func (*StkPayload) GetMerchantRequestId 

func (x *StkPayload) GetMerchantRequestId() string

func (*StkPayload) GetPayloadId 

func (x *StkPayload) GetPayloadId() string

func (*StkPayload) GetPhoneNumber 

func (x *StkPayload) GetPhoneNumber() string

func (*StkPayload) GetProcessed 

func (x *StkPayload) GetProcessed() bool

func (*StkPayload) GetResultCode 

func (x *StkPayload) GetResultCode() string

func (*StkPayload) GetResultDesc 

func (x *StkPayload) GetResultDesc() string

func (*StkPayload) GetSucceeded 

func (x *StkPayload) GetSucceeded() bool

func (*StkPayload) GetTransactionId 

func (x *StkPayload) GetTransactionId() string

func (*StkPayload) GetTransactionTimestamp 

func (x *StkPayload) GetTransactionTimestamp() int64

func (*StkPayload) ProtoMessage 

func (*StkPayload) ProtoMessage()

func (*StkPayload) ProtoReflect 

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

func (*StkPayload) Reset 

func (x *StkPayload) Reset()

func (*StkPayload) String 

func (x *StkPayload) String() string

type StkPushAPIClient 

type StkPushAPIClient interface {
	// Initiates mpesa payment.
	InitiateSTKPush(ctx context.Context, in *InitiateSTKPushRequest, opts ...grpc.CallOption) (*InitiateSTKPushResponse, error)
	// Retrieves a single stk payload
	GetStkPayload(ctx context.Context, in *GetStkPayloadRequest, opts ...grpc.CallOption) (*StkPayload, error)
	// Creates a record of stk push response sent to callback
	CreateStkPayload(ctx context.Context, in *CreateStkPayloadRequest, opts ...grpc.CallOption) (*StkPayload, error)
	// Retrieves a collection of stk push payloads
	ListStkPayloads(ctx context.Context, in *ListStkPayloadsRequest, opts ...grpc.CallOption) (*ListStkPayloadsResponse, error)
	// Processes stk push payload updating its status
	ProcessStkPayload(ctx context.Context, in *ProcessStkPayloadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Publishes stk push payload for consumers
	PublishStkPayload(ctx context.Context, in *PublishStkPayloadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Publihses all stk push payloads to consumers
	PublishAllStkPayload(ctx context.Context, in *PublishAllStkPayloadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

StkPushAPIClient is the client API for StkPushAPI service.

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

func NewStkPushAPIClient 

func NewStkPushAPIClient(cc grpc.ClientConnInterface) StkPushAPIClient

type StkPushAPIServer 

type StkPushAPIServer interface {
	// Initiates mpesa payment.
	InitiateSTKPush(context.Context, *InitiateSTKPushRequest) (*InitiateSTKPushResponse, error)
	// Retrieves a single stk payload
	GetStkPayload(context.Context, *GetStkPayloadRequest) (*StkPayload, error)
	// Creates a record of stk push response sent to callback
	CreateStkPayload(context.Context, *CreateStkPayloadRequest) (*StkPayload, error)
	// Retrieves a collection of stk push payloads
	ListStkPayloads(context.Context, *ListStkPayloadsRequest) (*ListStkPayloadsResponse, error)
	// Processes stk push payload updating its status
	ProcessStkPayload(context.Context, *ProcessStkPayloadRequest) (*emptypb.Empty, error)
	// Publishes stk push payload for consumers
	PublishStkPayload(context.Context, *PublishStkPayloadRequest) (*emptypb.Empty, error)
	// Publihses all stk push payloads to consumers
	PublishAllStkPayload(context.Context, *PublishAllStkPayloadRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

StkPushAPIServer is the server API for StkPushAPI service. All implementations must embed UnimplementedStkPushAPIServer for forward compatibility

type UnimplementedStkPushAPIServer 

type UnimplementedStkPushAPIServer struct {
}

UnimplementedStkPushAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedStkPushAPIServer) CreateStkPayload 

func (UnimplementedStkPushAPIServer) CreateStkPayload(context.Context, *CreateStkPayloadRequest) (*StkPayload, error)

func (UnimplementedStkPushAPIServer) GetStkPayload 

func (UnimplementedStkPushAPIServer) GetStkPayload(context.Context, *GetStkPayloadRequest) (*StkPayload, error)

func (UnimplementedStkPushAPIServer) InitiateSTKPush 

func (UnimplementedStkPushAPIServer) InitiateSTKPush(context.Context, *InitiateSTKPushRequest) (*InitiateSTKPushResponse, error)

func (UnimplementedStkPushAPIServer) ListStkPayloads 

func (UnimplementedStkPushAPIServer) ListStkPayloads(context.Context, *ListStkPayloadsRequest) (*ListStkPayloadsResponse, error)

func (UnimplementedStkPushAPIServer) ProcessStkPayload 

func (UnimplementedStkPushAPIServer) ProcessStkPayload(context.Context, *ProcessStkPayloadRequest) (*emptypb.Empty, error)

func (UnimplementedStkPushAPIServer) PublishAllStkPayload 

func (UnimplementedStkPushAPIServer) PublishAllStkPayload(context.Context, *PublishAllStkPayloadRequest) (*emptypb.Empty, error)

func (UnimplementedStkPushAPIServer) PublishStkPayload 

func (UnimplementedStkPushAPIServer) PublishStkPayload(context.Context, *PublishStkPayloadRequest) (*emptypb.Empty, error)

type UnsafeStkPushAPIServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.